diff options
| -rw-r--r-- | kafka/coordinator/base.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index e902dba..df3e339 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -712,6 +712,7 @@ class BaseCoordinator(object): with self._lock: if self._heartbeat_thread is not None: self._heartbeat_thread.close() + self._heartbeat_thread = None self.maybe_leave_group() def maybe_leave_group(self): |