diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-08-04 12:19:46 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-08-04 13:05:36 -0700 |
| commit | af08b54875a5ae5c14fbdeccee4ffe266bda1e00 (patch) | |
| tree | 51475b859960f304c74c47e0ce394f7451e5ddba /kafka/coordinator/base.py | |
| parent | a698162dc9bcb228007c4942105515f0eb720c2c (diff) | |
| download | kafka-python-af08b54875a5ae5c14fbdeccee4ffe266bda1e00.tar.gz | |
Treat metric_group_prefix as config in KafkaConsumer
Diffstat (limited to 'kafka/coordinator/base.py')
| -rw-r--r-- | kafka/coordinator/base.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index c57d45a..d6ea6c0 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -55,9 +55,10 @@ class BaseCoordinator(object): 'heartbeat_interval_ms': 3000, 'retry_backoff_ms': 100, 'api_version': (0, 9), + 'metric_group_prefix': '', } - def __init__(self, client, metrics, metric_group_prefix, **configs): + def __init__(self, client, metrics, **configs): """ Keyword Arguments: group_id (str): name of the consumer group to join for dynamic @@ -92,7 +93,7 @@ class BaseCoordinator(object): self.heartbeat = Heartbeat(**self.config) self.heartbeat_task = HeartbeatTask(weakref.proxy(self)) self.sensors = GroupCoordinatorMetrics(self.heartbeat, metrics, - metric_group_prefix) + self.config['metric_group_prefix']) def __del__(self): if hasattr(self, 'heartbeat_task') and self.heartbeat_task: |