Use for join-time-max and sync-time-max metrics Max() measure function (dpkp#1146)

Author: billyevans

kafka/coordinator/base.py

@@ -719,7 +719,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',
@@ -733,7 +733,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',