diff options
| author | Alexey Pervushin <pervushinai@gmail.com> | 2017-07-20 22:07:50 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-07-20 22:07:50 -0700 |
| commit | 165b897139ae69e5935c2618759773572781ef17 (patch) | |
| tree | afc5f4021ebab493df0cb6d912ac43db1c8a1211 | |
| parent | 0c78f704520a42d0935cb87298dd69f8e4af5894 (diff) | |
| download | kafka-python-165b897139ae69e5935c2618759773572781ef17.tar.gz | |
Use for join-time-max and sync-time-max metrics Max() measure function (#1146)
| -rw-r--r-- | kafka/coordinator/base.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index a231857..af0936c 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -721,7 +721,7 @@ class GroupCoordinatorMetrics(object): self.join_latency.add(metrics.metric_name( 'join-time-max', self.metric_group_name, 'The max time taken for a group rejoin', - tags), Avg()) + tags), Max()) self.join_latency.add(metrics.metric_name( 'join-rate', self.metric_group_name, 'The number of group joins per second', @@ -735,7 +735,7 @@ class GroupCoordinatorMetrics(object): self.sync_latency.add(metrics.metric_name( 'sync-time-max', self.metric_group_name, 'The max time taken for a group sync', - tags), Avg()) + tags), Max()) self.sync_latency.add(metrics.metric_name( 'sync-rate', self.metric_group_name, 'The number of group syncs per second', |