From a871aa60f3ac74bf88beff5b6df74d0466e2b0b0 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 17 Jul 2016 17:53:42 -0700 Subject: Add KafkaClient metrics --- kafka/producer/kafka.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'kafka/producer/kafka.py') diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index c4d1a36..02e4621 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -308,7 +308,8 @@ class KafkaProducer(object): reporters = [reporter() for reporter in self.config['metric_reporters']] self._metrics = Metrics(metric_config, reporters) - client = KafkaClient(**self.config) + client = KafkaClient(metrics=self._metrics, metric_group_prefix='producer', + **self.config) # Get auto-discovered version from client if necessary if self.config['api_version'] is None: -- cgit v1.2.1