Skip to content

Commit 8f82017

Browse files
YaoCdpkp
authored andcommitted
fix reconnect_backoff_max_ms default config bug in KafkaProducer (dpkp#1352)
1 parent 13490fa commit 8f82017

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka/producer/kafka.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -295,7 +295,7 @@ class KafkaProducer(object):
295295
'sock_chunk_bytes': 4096, # undocumented experimental option
296296
'sock_chunk_buffer_count': 1000, # undocumented experimental option
297297
'reconnect_backoff_ms': 50,
298-
'reconnect_backoff_max': 1000,
298+
'reconnect_backoff_max_ms': 1000,
299299
'max_in_flight_requests_per_connection': 5,
300300
'security_protocol': 'PLAINTEXT',
301301
'ssl_context': None,

0 commit comments

Comments
 (0)