diff options
| author | Taras Voinarovskyi <voyn1991@gmail.com> | 2017-07-18 02:39:37 +0300 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-07-17 16:39:37 -0700 |
| commit | c8237fc53bf93c72a5530a53654dd3133a96de08 (patch) | |
| tree | bf288b80a164818d02218d61e93fdafa13b28e0f | |
| parent | 6f0395786aa35fb091cdc05256f5b3d34e250351 (diff) | |
| download | kafka-python-c8237fc53bf93c72a5530a53654dd3133a96de08.tar.gz | |
Add note, that `max_in_flight_requests_per_connection>1` may change order or messages (#1149)
| -rw-r--r-- | kafka/producer/kafka.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index 97741aa..09ca744 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -209,7 +209,10 @@ class KafkaProducer(object): the computed value. Default: 1000. max_in_flight_requests_per_connection (int): Requests are pipelined 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. Valid values are: PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL. Default: PLAINTEXT. |