diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-01-10 13:36:41 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-01-10 13:38:12 -0800 |
| commit | 02a3034e95a06c9de00eb6add616b9138d9bcf24 (patch) | |
| tree | e25e986965144b1dc5b8e6c12d58794178d0275a /kafka/coordinator/consumer.py | |
| parent | 794b695e7ceff25834616bb54e32160104040df4 (diff) | |
| download | kafka-python-reference_cleanup_close.tar.gz | |
Improve KafkaConsumer cleanupreference_cleanup_close
Diffstat (limited to 'kafka/coordinator/consumer.py')
| -rw-r--r-- | kafka/coordinator/consumer.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py index 48dcad4..ab30883 100644 --- a/kafka/coordinator/consumer.py +++ b/kafka/coordinator/consumer.py @@ -125,6 +125,7 @@ class ConsumerCoordinator(BaseCoordinator): def __del__(self): if hasattr(self, '_cluster') and self._cluster: self._cluster.remove_listener(WeakMethod(self._handle_metadata_update)) + super(ConsumerCoordinator, self).__del__() def protocol_type(self): return ConsumerProtocol.PROTOCOL_TYPE |