summaryrefslogtreecommitdiff
path: root/kafka
diff options
context:
space:
mode:
authorMark Roberts <wizzat@gmail.com>2015-02-02 10:16:33 -0800
committerMark Roberts <wizzat@gmail.com>2015-02-02 10:16:33 -0800
commitf0f37445b483b413cfe1ec900d033a3c9325e6e9 (patch)
tree8834fbd48e7cacaf2601d5a813517472d1a275b5 /kafka
parent4379355450bcaf47ec9ce821e2d9a09e07f77bbe (diff)
parent72bec18adde851510c1c627ce8dee659425f727b (diff)
downloadkafka-python-f0f37445b483b413cfe1ec900d033a3c9325e6e9.tar.gz
Merge pull request #306 from sontek/catch_topic_not_bytes
Alert if the topic is not sent as bytes
Diffstat (limited to 'kafka')
-rw-r--r--kafka/producer/simple.py8
1 files changed, 7 insertions, 1 deletions
diff --git a/kafka/producer/simple.py b/kafka/producer/simple.py
index afeae06..2699cf2 100644
--- a/kafka/producer/simple.py
+++ b/kafka/producer/simple.py
@@ -2,6 +2,7 @@ from __future__ import absolute_import
import logging
import random
+import six
from itertools import cycle
@@ -68,8 +69,13 @@ class SimpleProducer(Producer):
return next(self.partition_cycles[topic])
def send_messages(self, topic, *msg):
+ if not isinstance(topic, six.binary_type):
+ topic = topic.encode('utf-8')
+
partition = self._next_partition(topic)
- return super(SimpleProducer, self).send_messages(topic, partition, *msg)
+ return super(SimpleProducer, self).send_messages(
+ topic, partition, *msg
+ )
def __repr__(self):
return '<SimpleProducer batch=%s>' % self.async