summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--kafka/metrics/stats/sensor.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/metrics/stats/sensor.py b/kafka/metrics/stats/sensor.py
index 6878096..b0bf4db 100644
--- a/kafka/metrics/stats/sensor.py
+++ b/kafka/metrics/stats/sensor.py
@@ -64,7 +64,7 @@ class Sensor(object):
now = time.time() * 1000
if time_ms is None:
time_ms = now
- self._last_record_time = now
+ self._last_record_time = time_ms
with self._lock: # XXX high volume, might be performance issue
# increment all the stats
for stat in self._stats: