openstack/deb-python-kafka
Code Issues Proposed changes

Add note, that max_in_flight_requests_per_connection>1 may change order or messages (#1149)

Browse Source
This commit is contained in:
Taras Voinarovskyi
2017-07-18 02:39:37 +03:00
committed by Dana Powers
parent 6f0395786a
commit c8237fc53b
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
kafka/producer/kafka.py
View File

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