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 6f03957 commit c8237fcCopy full SHA for c8237fc
kafka/producer/kafka.py
@@ -209,7 +209,10 @@ class KafkaProducer(object):
209
the computed value. Default: 1000.
210
max_in_flight_requests_per_connection (int): Requests are pipelined
211
to kafka brokers up to this number of maximum requests per
212
- broker connection. Default: 5.
+ 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.
216
security_protocol (str): Protocol used to communicate with brokers.
217
Valid values are: PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL.
218
Default: PLAINTEXT.
0 commit comments