From 9288ccd322217c6f4fcc297b61027c52dd0197df Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 20 May 2025 16:30:18 -0700 Subject: [PATCH] Fix timeout seconds error message in KafkaProducer --- kafka/producer/kafka.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index 66208bbe1..2416cc3ef 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -944,7 +944,7 @@ def _wait_on_metadata(self, topic, max_wait_ms): """ # add topic to metadata topic list if it is not there already. self._sender.add_topic(topic) - timer = Timer(max_wait_ms, "Failed to update metadata after %.1f secs." % (max_wait_ms * 1000,)) + timer = Timer(max_wait_ms, "Failed to update metadata after %.1f secs." % (max_wait_ms / 1000,)) metadata_event = None while True: partitions = self._metadata.partitions_for_topic(topic) @@ -962,7 +962,7 @@ def _wait_on_metadata(self, topic, max_wait_ms): metadata_event.wait(timer.timeout_ms / 1000) if not metadata_event.is_set(): raise Errors.KafkaTimeoutError( - "Failed to update metadata after %.1f secs." % (max_wait_ms * 1000,)) + "Failed to update metadata after %.1f secs." % (max_wait_ms / 1000,)) elif topic in self._metadata.unauthorized_topics: raise Errors.TopicAuthorizationFailedError(set([topic])) else: