summaryrefslogtreecommitdiff
path: root/kafka/client.py
diff options
context:
space:
mode:
authorMahendra M <mahendra.m@gmail.com>2013-06-13 18:50:14 +0530
committerMahendra M <mahendra.m@gmail.com>2013-06-13 18:50:14 +0530
commit604d78bf58e00cd8fc926b5db5206396c63e4286 (patch)
tree450c54e4e93fe1cb5a3e4e9341db2b6a7e44c20f /kafka/client.py
parent337127a77dc749224bd7645893950ed90f76f134 (diff)
parent883eed1f8ce1af37c621ad6ec89dc993694fd29b (diff)
downloadkafka-python-604d78bf58e00cd8fc926b5db5206396c63e4286.tar.gz
Merge branch 'master' into asyncproducer
Conflicts: kafka/producer.py
Diffstat (limited to 'kafka/client.py')
-rw-r--r--kafka/client.py5
1 files changed, 5 insertions, 0 deletions
diff --git a/kafka/client.py b/kafka/client.py
index 5595d49..1146798 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -73,7 +73,12 @@ class KafkaClient(object):
self.brokers.update(brokers)
self.topics_to_brokers = {}
+
for topic, partitions in topics.items():
+ # Clear the list once before we add it. This removes stale entries
+ # and avoids duplicates
+ self.topic_partitions.pop(topic, None)
+
if not partitions:
log.info("Partition is unassigned, delay for 1s and retry")
time.sleep(1)