diff options
| -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 |