producer/kafka: Disable logging during object destruction (#2043)

dpkp · Sep 7, 2020 · e4913db · e4913db
1 parent 3a9d830
commit e4913db
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py
@@ -449,6 +449,14 @@ def _unregister_cleanup(self):
         self._cleanup = None
 
     def __del__(self):
+        # Disable logger during destruction to avoid touching dangling references
+        class NullLogger(object):
+            def __getattr__(self, name):
+                return lambda *args: None
+
+        global log
+        log = NullLogger()
+
         self.close()
 
     def close(self, timeout=None):