openstack/deb-python-kafka
Code Issues Proposed changes

Handle new topic creation / LeaderNotAvailableError in initial SimpleProducer.send_messages call

Browse Source
This commit is contained in:
Dana Powers
2015-12-16 22:39:51 -08:00
parent 7d4161f6d2
commit 178a1dccd8
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/producer/simple.py
View File

@@ -33,7 +33,7 @@ class SimpleProducer(Producer):
def _next_partition(self, topic):
if topic not in self.partition_cycles:
if not self.client.has_metadata_for_topic(topic):
self.client.load_metadata_for_topics(topic)
self.client.ensure_topic_exists(topic)
self.partition_cycles[topic] = cycle(self.client.get_partition_ids_for_topic(topic))