Changing some commented out metrics to avoid future gotchas.

zackdever · zackdever · commit 00d1a8b5f9fb · 2016-04-13T17:26:39.000-07:00
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py
@@ -681,7 +681,7 @@ def __init__(self, metrics, prefix):
         self.fetch_latency.add(metrics.metricName("fetch-latency-max", self.group_name,
             "The max time taken for any fetch request."), metrics.Max())
         self.fetch_latency.add(metrics.metricName("fetch-rate", self.group_name,
-            "The number of fetch requests per second."), metrics.Rate(metrics.Count()))
+            "The number of fetch requests per second."), metrics.Rate(sampled_stat=metrics.Count()))
 
         self.records_fetch_lag = metrics.sensor("records-lag")
         self.records_fetch_lag.add(metrics.metricName("records-lag-max", self.group_name,
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py
@@ -658,7 +658,7 @@ def __init__(self, metrics, prefix, tags=None):
         self.heartbeat_latency.add(metrics.metricName(
             "heartbeat-rate", self.group_name,
             "The average number of heartbeats per second",
-            tags), metrics.Rate(metrics.Count()))
+            tags), metrics.Rate(sampled_stat=metrics.Count()))
 
         self.join_latency = metrics.sensor("join-latency")
         self.join_latency.add(metrics.metricName(
@@ -672,7 +672,7 @@ def __init__(self, metrics, prefix, tags=None):
         self.join_latency.add(metrics.metricName(
             "join-rate", self.group_name,
             "The number of group joins per second",
-            tags), metrics.Rate(metrics.Count()))
+            tags), metrics.Rate(sampled_stat=metrics.Count()))
 
         self.sync_latency = metrics.sensor("sync-latency")
         self.sync_latency.add(metrics.metricName(
@@ -686,7 +686,7 @@ def __init__(self, metrics, prefix, tags=None):
         self.sync_latency.add(metrics.metricName(
             "sync-rate", self.group_name,
             "The number of group syncs per second",
-            tags), metrics.Rate(metrics.Count()))
+            tags), metrics.Rate(sampled_stat=metrics.Count()))
 
         """
         lastHeartbeat = Measurable(
