Heartbeat thread start / closeheartbeat_logging

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: