diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-05-22 19:21:35 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-05-22 19:21:35 -0700 |
| commit | b000303045e7e4e7d65cf369f91661cad943992c (patch) | |
| tree | 3b0717a0dd09a77365cc9870e9ddae14f5a938b0 /kafka/producer/kafka.py | |
| parent | 42293725e5361fd6e6fd38b0ac58afda82e94d3a (diff) | |
| download | kafka-python-b000303045e7e4e7d65cf369f91661cad943992c.tar.gz | |
KAFKA-3197: when max.in.flight.request.per.connection = 1, attempt to guarantee ordering (#698)
Diffstat (limited to 'kafka/producer/kafka.py')
| -rw-r--r-- | kafka/producer/kafka.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index fc60e78..0793c80 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -286,7 +286,9 @@ class KafkaProducer(object): message_version = 1 if self.config['api_version'] >= (0, 10) else 0 self._accumulator = RecordAccumulator(message_version=message_version, **self.config) self._metadata = client.cluster + guarantee_message_order = bool(self.config['max_in_flight_requests_per_connection'] == 1) self._sender = Sender(client, self._metadata, self._accumulator, + guarantee_message_order=guarantee_message_order, **self.config) self._sender.daemon = True self._sender.start() |