From 02a3034e95a06c9de00eb6add616b9138d9bcf24 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Wed, 10 Jan 2018 13:36:41 -0800
Subject: Improve KafkaConsumer cleanup

---
 kafka/coordinator/consumer.py | 1 +
 1 file changed, 1 insertion(+)

(limited to 'kafka/coordinator/consumer.py')

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
-- 
cgit v1.2.1