Skip to content

Commit 96b6211

Browse files
tvoinarovskyi88manpreet
authored andcommitted
Add note, that max_in_flight_requests_per_connection>1 may change order or messages (dpkp#1149)
1 parent 5fe34e3 commit 96b6211

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

kafka/producer/kafka.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -208,7 +208,10 @@ class KafkaProducer(object):
208208
the computed value. Default: 1000.
209209
max_in_flight_requests_per_connection (int): Requests are pipelined
210210
to kafka brokers up to this number of maximum requests per
211-
broker connection. Default: 5.
211+
broker connection. Note that if this setting is set to be greater
212+
than 1 and there are failed sends, there is a risk of message
213+
re-ordering due to retries (i.e., if retries are enabled).
214+
Default: 5.
212215
security_protocol (str): Protocol used to communicate with brokers.
213216
Valid values are: PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL.
214217
Default: PLAINTEXT.

0 commit comments

Comments
 (0)