We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
max_in_flight_requests_per_connection>1
1 parent 839fad4 commit f2931ebCopy full SHA for f2931eb
kafka/producer/kafka.py
@@ -208,7 +208,10 @@ class KafkaProducer(object):
208
the computed value. Default: 1000.
209
max_in_flight_requests_per_connection (int): Requests are pipelined
210
to kafka brokers up to this number of maximum requests per
211
- broker connection. Default: 5.
+ 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.
215
security_protocol (str): Protocol used to communicate with brokers.
216
Valid values are: PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL.
217
Default: PLAINTEXT.
0 commit comments