diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-02-15 16:15:50 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-02-15 16:15:50 -0800 |
| commit | 89b4c2ff37205f9b76be6d398d75ec5214919468 (patch) | |
| tree | 83ffb0b99b24531937a3932ffb6b3632f2666ddb /kafka/cluster.py | |
| parent | ca7cd0dd1172c337dda1d719b3b5c49a02da97d9 (diff) | |
| download | kafka-python-89b4c2ff37205f9b76be6d398d75ec5214919468.tar.gz | |
Remove unused cluster._version private attribute
Diffstat (limited to 'kafka/cluster.py')
| -rw-r--r-- | kafka/cluster.py | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/kafka/cluster.py b/kafka/cluster.py index d766fa3..a0053d6 100644 --- a/kafka/cluster.py +++ b/kafka/cluster.py @@ -26,7 +26,6 @@ class ClusterMetadata(object): self._partitions = {} self._broker_partitions = collections.defaultdict(set) self._groups = {} - self._version = 0 self._last_refresh_ms = 0 self._last_successful_refresh_ms = 0 self._need_update = False @@ -158,12 +157,10 @@ class ClusterMetadata(object): self._future.success(self) self._future = None self._need_update = False - self._version += 1 now = time.time() * 1000 self._last_refresh_ms = now self._last_successful_refresh_ms = now - log.debug("Updated cluster metadata version %d to %s", - self._version, self) + log.debug("Updated cluster metadata to %s", self) for listener in self._listeners: listener(self) |