diff options
| -rw-r--r-- | kafka/producer/base.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py index 87d923a..8544d73 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -89,11 +89,11 @@ def _send_upstream(queue, client, codec, batch_time, batch_size, failed_reqs = ex.args[0] log.exception("Failed payloads count %s" % len(failed_reqs)) + # if no limit, retry all failed messages until success if retries_limit is None: - # retry all failed messages until success reqs_to_retry = failed_reqs - elif not retries_limit < 0: - # + # makes sense to check failed reqs only if we have a limit > 0 + elif retries_limit > 0: for req in failed_reqs: if retries_limit and req.retries < retries_limit: updated_req = req._replace(retries=req.retries+1) |