diff options
| author | Zack Dever <zackdever@gmail.com> | 2016-05-03 18:21:14 -0700 |
|---|---|---|
| committer | Zack Dever <zackdever@gmail.com> | 2016-05-03 18:21:14 -0700 |
| commit | 0684302d8fa1271ad0e913972b382b00ddeab717 (patch) | |
| tree | dd8349c466ae2c6c64a9b671d6f2c57024191005 | |
| parent | d401bde9ed64d5d50b7ecd1f6bdf3f3c664bb075 (diff) | |
| parent | 416f50b6f78328878e950d7bd8dd902c52d35b13 (diff) | |
| download | kafka-python-0684302d8fa1271ad0e913972b382b00ddeab717.tar.gz | |
Merge pull request #679 from zackdever/kafka-PR-1265-bugfix
small bug fix in Sensor
| -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: |