diff options
| author | C.YAO <YaoC@users.noreply.github.com> | 2018-01-24 01:48:58 +0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-01-23 09:48:58 -0800 |
| commit | 8f8201713676db2f6ea3828cc376cbed2665dcd2 (patch) | |
| tree | d9cc09008fcdbdbaa7f56dba712ecb960e457acc | |
| parent | 13490fa2b17a8ad909b11a243aaf38ba491293ee (diff) | |
| download | kafka-python-8f8201713676db2f6ea3828cc376cbed2665dcd2.tar.gz | |
fix reconnect_backoff_max_ms default config bug in KafkaProducer (#1352)
| -rw-r--r-- | kafka/producer/kafka.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index d24236a..5e2fb69 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -295,7 +295,7 @@ class KafkaProducer(object): 'sock_chunk_bytes': 4096, # undocumented experimental option 'sock_chunk_buffer_count': 1000, # undocumented experimental option 'reconnect_backoff_ms': 50, - 'reconnect_backoff_max': 1000, + 'reconnect_backoff_max_ms': 1000, 'max_in_flight_requests_per_connection': 5, 'security_protocol': 'PLAINTEXT', 'ssl_context': None, |