diff options
| author | Mika Eloranta <mel@aiven.io> | 2017-07-18 02:39:04 +0300 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-07-17 16:39:04 -0700 |
| commit | 6f0395786aa35fb091cdc05256f5b3d34e250351 (patch) | |
| tree | 38dd45b334af1231327dedcd2acd5ec72450b2ce | |
| parent | d0c6b1f95c2e677545d1faaeae525e8768abea9e (diff) | |
| download | kafka-python-6f0395786aa35fb091cdc05256f5b3d34e250351.tar.gz | |
producer: fix produce timeout message (#1151)
| -rw-r--r-- | kafka/producer/kafka.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index bd891c9..97741aa 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -625,7 +625,7 @@ class KafkaProducer(object): elapsed = time.time() - begin if not metadata_event.is_set(): raise Errors.KafkaTimeoutError( - "Failed to update metadata after %s secs.", max_wait) + "Failed to update metadata after %.1f secs." % max_wait) elif topic in self._metadata.unauthorized_topics: raise Errors.TopicAuthorizationFailedError(topic) else: |