diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-07-17 17:53:42 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-07-17 17:54:06 -0700 |
| commit | a871aa60f3ac74bf88beff5b6df74d0466e2b0b0 (patch) | |
| tree | ba340ae33cdc9749dbd36f5954ff0e1bcd2cace7 /kafka/producer/kafka.py | |
| parent | f8b8904491a4ac19c80aa827ec42f3356424800d (diff) | |
| download | kafka-python-more_metrics.tar.gz | |
Add KafkaClient metricsmore_metrics
Diffstat (limited to 'kafka/producer/kafka.py')
| -rw-r--r-- | kafka/producer/kafka.py | 3 |
1 files changed, 2 insertions, 1 deletions
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: |