From 085e72b72230304da80729aa431b43233e851424 Mon Sep 17 00:00:00 2001 From: billyevans Date: Wed, 12 Jul 2017 15:49:52 -0700 Subject: [PATCH] Use for join-time-max and sync-time-max metrics Max() measure function instead of Avg() --- kafka/coordinator/base.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index a2318574d..af0936c9d 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -721,7 +721,7 @@ def __init__(self, heartbeat, metrics, prefix, tags=None): 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 @@ def __init__(self, heartbeat, metrics, prefix, tags=None): 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',