From c8237fc53bf93c72a5530a53654dd3133a96de08 Mon Sep 17 00:00:00 2001 From: Taras Voinarovskyi Date: Tue, 18 Jul 2017 02:39:37 +0300 Subject: Add note, that `max_in_flight_requests_per_connection>1` may change order or messages (#1149) --- kafka/producer/kafka.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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. -- cgit v1.2.1