diff options
| -rw-r--r-- | kafka/coordinator/base.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 9d1872a..da37f92 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -910,11 +910,10 @@ class HeartbeatThread(threading.Thread): def run(self): try: + log.debug('Heartbeat thread started') while not self.closed: self._run_once() - log.debug('Heartbeat thread closed') - except ReferenceError: log.debug('Heartbeat thread closed due to coordinator gc') @@ -923,6 +922,9 @@ class HeartbeatThread(threading.Thread): self.coordinator.group_id, e) self.failed = e + finally: + log.debug('Heartbeat thread closed') + def _run_once(self): with self.coordinator._lock: if not self.enabled: |