diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-08-04 14:22:40 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2016-08-04 14:22:40 -0700 |
| commit | 68c8fa4ad01f8fef38708f257cb1c261cfac01ab (patch) | |
| tree | 38d12fc11f82c492c68a4e04dbac26664862f541 /kafka/producer/kafka.py | |
| parent | 3c9b1b6fc498f95806ee12f67f84ea548ac1378f (diff) | |
| parent | 025b69ef4ae22d1677904e99f924b9ef5a096e75 (diff) | |
| download | kafka-python-68c8fa4ad01f8fef38708f257cb1c261cfac01ab.tar.gz | |
Merge pull request #794 from dpkp/conn_metrics
Complete metrics instrumentation
Diffstat (limited to 'kafka/producer/kafka.py')
| -rw-r--r-- | kafka/producer/kafka.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index e3b0d69..84039f6 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -335,7 +335,7 @@ class KafkaProducer(object): assert self.config['api_version'] >= (0, 8, 2), 'LZ4 Requires >= Kafka 0.8.2 Brokers' message_version = 1 if self.config['api_version'] >= (0, 10) else 0 - self._accumulator = RecordAccumulator(message_version=message_version, **self.config) + self._accumulator = RecordAccumulator(message_version=message_version, metrics=self._metrics, **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, |