Skip to content

Commit 839fad4

Browse files
Mika Eloranta88manpreet
authored andcommitted
producer: fix produce timeout message (dpkp#1151)
1 parent 239d56f commit 839fad4

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka/producer/kafka.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -619,7 +619,7 @@ def _wait_on_metadata(self, topic, max_wait):
619619
elapsed = time.time() - begin
620620
if not metadata_event.is_set():
621621
raise Errors.KafkaTimeoutError(
622-
"Failed to update metadata after %s secs.", max_wait)
622+
"Failed to update metadata after %.1f secs." % max_wait)
623623
elif topic in self._metadata.unauthorized_topics:
624624
raise Errors.TopicAuthorizationFailedError(topic)
625625
else:

0 commit comments

Comments
 (0)