diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-10-23 15:42:40 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-12-21 11:39:25 -0800 |
| commit | a709cc5016bd28482832152722e84cf78af53ff5 (patch) | |
| tree | f1993351b2c6487e8e623cefabf42ddf7477f666 | |
| parent | e0391088f3f495e364229ad18592fc2eea348ef6 (diff) | |
| download | kafka-python-KAFKA_3888_heartbeat_thread.tar.gz | |
Fix lookup future is_done checkKAFKA_3888_heartbeat_thread
| -rw-r--r-- | kafka/coordinator/base.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 5e6e19f..b16c1e1 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -919,7 +919,7 @@ class HeartbeatThread(threading.Thread): self.coordinator._client.poll(timeout_ms=0) if self.coordinator.coordinator_unknown(): - if not self.coordinator.lookup_coordinator().is_done(): + if not self.coordinator.lookup_coordinator().is_done: self.coordinator._lock.wait(self.coordinator.config['retry_backoff_ms'] / 1000) elif self.coordinator.heartbeat.session_timeout_expired(): |