diff options
Diffstat (limited to 'kafka/client.py')
-rw-r--r-- | kafka/client.py | 7 |
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): |