diff options
| -rw-r--r-- | kafka/producer/base.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py index 602e2ed..2e2f3c4 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -126,8 +126,8 @@ def _send_upstream(queue, client, codec, batch_time, batch_size, if error_type in RETRY_REFRESH_ERROR_TYPES: client.load_metadata_for_topics() - reqs = {key: count + 1 for key, count in reqs.items() - if key in reqs_to_retry and count < retry_options.limit} + reqs = dict((key, count + 1) for (key, count) in reqs.items() + if key in reqs_to_retry and count < retry_options.limit) class Producer(object): |