diff options
| author | Zack Dever <zackdever@gmail.com> | 2016-05-03 17:43:50 -0700 |
|---|---|---|
| committer | Zack Dever <zackdever@gmail.com> | 2016-05-03 17:43:50 -0700 |
| commit | 416f50b6f78328878e950d7bd8dd902c52d35b13 (patch) | |
| tree | 5749babbdf46a20f9e88a81af662be8e6177558a | |
| parent | 874f4874a7a126c27abff5e436e79602ef0983f9 (diff) | |
| download | kafka-python-416f50b6f78328878e950d7bd8dd902c52d35b13.tar.gz | |
small bug fix in Sensor
pulling in this small bug fix from https://github.com/apache/kafka/pull/1265/files#diff-8736b7fd8ad077ea55ea2a8ad61285faR99
| -rw-r--r-- | kafka/metrics/stats/sensor.py | 2 |
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: |