Skip to content

Commit c8237fc

Browse files
tvoinarovskyidpkp
authored andcommitted
Add note, that max_in_flight_requests_per_connection>1 may change order or messages (dpkp#1149)
1 parent 6f03957 commit c8237fc

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
@@ -209,7 +209,10 @@ class KafkaProducer(object):
209209
the computed value. Default: 1000.
210210
max_in_flight_requests_per_connection (int): Requests are pipelined
211211
to kafka brokers up to this number of maximum requests per
212-
broker connection. Default: 5.
212+
broker connection. Note that if this setting is set to be greater
213+
than 1 and there are failed sends, there is a risk of message
214+
re-ordering due to retries (i.e., if retries are enabled).
215+
Default: 5.
213216
security_protocol (str): Protocol used to communicate with brokers.
214217
Valid values are: PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL.
215218
Default: PLAINTEXT.

0 commit comments

Comments
 (0)