try / except in consumer coordinator __del__

Author: dpkp

kafka/coordinator/consumer.py

@@ -128,7 +128,10 @@ def __init__(self, client, subscription, metrics, **configs):
 
     def __del__(self):
         if hasattr(self, '_cluster') and self._cluster:
-            self._cluster.remove_listener(WeakMethod(self._handle_metadata_update))
+            try:
+                self._cluster.remove_listener(WeakMethod(self._handle_metadata_update))
+            except TypeError:
+                pass
         super(ConsumerCoordinator, self).__del__()
 
     def protocol_type(self):