Heartbeat thread start / close

Author: dpkp

kafka/coordinator/base.py

@@ -910,11 +910,10 @@ def close(self):
 
     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 @@ def run(self):
                       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: