diff options
| -rw-r--r-- | kafka/producer/kafka.py | 5 |
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() |