From c5f9f29fb32afade55a0e62f70b1121dfedae607 Mon Sep 17 00:00:00 2001 From: "C.YAO" Date: Tue, 23 Jan 2018 17:28:23 +0800 Subject: [PATCH] fix config bug change 'reconnect_backoff_max' to 'reconnect_backoff_max_ms' in DEFAULT_CONFIG --- kafka/producer/kafka.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index d24236aa4..5e2fb6900 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,