diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-08-04 12:54:53 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-08-04 13:11:20 -0700 |
| commit | 025b69ef4ae22d1677904e99f924b9ef5a096e75 (patch) | |
| tree | 38d12fc11f82c492c68a4e04dbac26664862f541 /kafka/producer/kafka.py | |
| parent | 460f0784a30f303b4543763ca330cce52d6054eb (diff) | |
| download | kafka-python-conn_metrics.tar.gz | |
Instrument bufferpool-wait-ratio metric in KafkaProducerconn_metrics
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, |