diff options
| author | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-04-21 17:51:39 +0300 |
|---|---|---|
| committer | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-06-03 11:22:48 +0300 |
| commit | c165f17338c0a9260a91b816f73e5ce4ff7ed359 (patch) | |
| tree | ec7cbad3846b93ac6074c3608d5835f667dcc204 | |
| parent | b31114520a15477da7ad660765a0240b6f348944 (diff) | |
| download | kafka-python-c165f17338c0a9260a91b816f73e5ce4ff7ed359.tar.gz | |
Disable retry on timeouts by default (old behaviour)
| -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 |