summaryrefslogtreecommitdiff
path: root/kafka/client.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/client.py')
-rw-r--r--kafka/client.py7
1 files changed, 4 insertions, 3 deletions
diff --git a/kafka/client.py b/kafka/client.py
index 155f658..e6b3ca9 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -243,9 +243,10 @@ class KafkaClient(object):
self.topic_partitions[topic] = []
for partition, meta in partitions.items():
- topic_part = TopicAndPartition(topic, partition)
- self.topics_to_brokers[topic_part] = brokers[meta.leader]
- self.topic_partitions[topic].append(partition)
+ if meta.leader != -1:
+ topic_part = TopicAndPartition(topic, partition)
+ self.topics_to_brokers[topic_part] = brokers[meta.leader]
+ self.topic_partitions[topic].append(partition)
def send_produce_request(self, payloads=[], acks=1, timeout=1000,
fail_on_error=True, callback=None):