summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2014-12-11 16:36:12 -0800
committerDana Powers <dana.powers@rd.io>2014-12-15 12:43:45 -0800
commitd27d49fd6b1c02dc764035cb06c3b47bf2a4b7a5 (patch)
treefe7c5aec66df71c0ee907028a4fc3e65655f6115
parented893c3bcfdf54f440b98b958c86fc0c13573b6f (diff)
downloadkafka-python-d27d49fd6b1c02dc764035cb06c3b47bf2a4b7a5.tar.gz
Fixup call to self._client.get_partition_ids_for_topic -- use encoded topic bytes
-rw-r--r--kafka/consumer/kafka.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer/kafka.py b/kafka/consumer/kafka.py
index f4eb6cb..f07bedf 100644
--- a/kafka/consumer/kafka.py
+++ b/kafka/consumer/kafka.py
@@ -228,7 +228,7 @@ class KafkaConsumer(object):
if isinstance(arg, (six.string_types, six.binary_type)):
topic = kafka_bytestring(arg)
- for partition in self._client.get_partition_ids_for_topic(arg):
+ for partition in self._client.get_partition_ids_for_topic(topic):
self._consume_topic_partition(topic, partition)
# (topic, partition [, offset]) tuple