summaryrefslogtreecommitdiff
path: root/kafka/client.py
diff options
context:
space:
mode:
authorBruno ReniƩ <brutasse@gmail.com>2014-08-28 22:18:10 +0200
committerMark Roberts <wizzat@fb.com>2014-09-03 09:55:45 -0700
commit492792ecb3808db5b6b32ccd96979a813fa64878 (patch)
treeaadfd9b8291517d09161cc18ba49c27581148ad0 /kafka/client.py
parent5806dfbde82d781f37a99ede182224470a4f937e (diff)
downloadkafka-python-492792ecb3808db5b6b32ccd96979a813fa64878.tar.gz
client_id in bytes
Diffstat (limited to 'kafka/client.py')
-rw-r--r--kafka/client.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/client.py b/kafka/client.py
index 89664fc..e098470 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -20,7 +20,7 @@ log = logging.getLogger("kafka")
class KafkaClient(object):
- CLIENT_ID = "kafka-python"
+ CLIENT_ID = b"kafka-python"
ID_GEN = itertools.count()
# NOTE: The timeout given to the client should always be greater than the