diff options
| author | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-02-26 17:26:56 +0300 |
|---|---|---|
| committer | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-06-03 11:22:47 +0300 |
| commit | b0a04595c6aee7f6fcaa8927fcdfcd9a04a9b7d3 (patch) | |
| tree | b809fe815141f6fd03fbeddd08c4ca3c4a4cfcba | |
| parent | 566e408da0aa7fb1bb74fae96231c94cc4a12e37 (diff) | |
| download | kafka-python-b0a04595c6aee7f6fcaa8927fcdfcd9a04a9b7d3.tar.gz | |
Returned default behaviour with no retries
| -rw-r--r-- | kafka/producer/base.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py index 8544d73..44ffdf4 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -26,7 +26,7 @@ log = logging.getLogger("kafka") BATCH_SEND_DEFAULT_INTERVAL = 20 BATCH_SEND_MSG_COUNT = 20 BATCH_RETRY_BACKOFF_MS = 300 -BATCH_RETRIES_LIMIT = 5 +BATCH_RETRIES_LIMIT = 0 STOP_ASYNC_PRODUCER = -1 |