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 a989e3f..331c71c 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -29,7 +29,7 @@ log = logging.getLogger("kafka") BATCH_SEND_DEFAULT_INTERVAL = 20 BATCH_SEND_MSG_COUNT = 20 BATCH_RETRY_OPTIONS = RetryOptions( - limit=0, backoff_ms=300, retry_on_timeouts=True) + limit=0, backoff_ms=300, retry_on_timeouts=False) STOP_ASYNC_PRODUCER = -1 |