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/coordinator/base.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/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: |