From e99a751081f59189ed818220100a1db2d8a13b6f Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sat, 4 Apr 2015 13:57:15 -0700 Subject: [PATCH] Fix python3 str/bytes bug in KafkaConsumer.set_topic_partitions({(topic, partition): offset, }) --- kafka/consumer/kafka.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/consumer/kafka.py b/kafka/consumer/kafka.py index 6f5bcdd..59597d9 100644 --- a/kafka/consumer/kafka.py +++ b/kafka/consumer/kafka.py @@ -224,7 +224,7 @@ class KafkaConsumer(object): topic = kafka_bytestring(key[0]) partition = key[1] self._consume_topic_partition(topic, partition) - self._offsets.fetch[key] = value + self._offsets.fetch[(topic, partition)] = value else: raise KafkaConfigurationError('Unknown topic type (%s)' % type(arg))