diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-04-04 13:57:15 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-04-04 13:57:15 -0700 |
| commit | e99a751081f59189ed818220100a1db2d8a13b6f (patch) | |
| tree | cbf79b6c5cb0e71d34bffebfef323329409cd2c0 | |
| parent | 46ee816327ece5759c0125fdbf799171fb5a021f (diff) | |
| download | kafka-python-e99a751081f59189ed818220100a1db2d8a13b6f.tar.gz | |
Fix python3 str/bytes bug in KafkaConsumer.set_topic_partitions({(topic, partition): offset, })
| -rw-r--r-- | kafka/consumer/kafka.py | 2 |
1 files changed, 1 insertions, 1 deletions
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)) |