Merge pull request #598 from zackdever/producer-optimization

Producer optimization

1 files changed, 4 insertions, 1 deletions

diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py
index 0286f8b..2a16fd8 100644
--- a/kafka/producer/kafka.py
+++ b/kafka/producer/kafka.py
@@ -443,12 +443,15 @@ class KafkaProducer(object):
         self._sender.add_topic(topic)
         begin = time.time()
         elapsed = 0.0
-        metadata_event = threading.Event()
+        metadata_event = None
         while True:
             partitions = self._metadata.partitions_for_topic(topic)
             if partitions is not None:
                 return partitions
 
+            if not metadata_event:
+                metadata_event = threading.Event()
+
             log.debug("Requesting metadata update for topic %s", topic)
 
             metadata_event.clear()