diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-10-22 09:08:06 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-12-21 11:39:25 -0800 |
| commit | e579490d8acaaf4fc75a08bb41ad576bcf200fb2 (patch) | |
| tree | 1c7fa198818cb9730dbecee4ff3a5718a01d4ec3 | |
| parent | 3432a0bf5285cbd1d75bfc7728d2ab56aa748d42 (diff) | |
| download | kafka-python-e579490d8acaaf4fc75a08bb41ad576bcf200fb2.tar.gz | |
Drop heartbeat_thread reference after close
| -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): |