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

layer9ai · Jun 9, 2021 · bddf777 · bddf777
1 parent 0552b04
commit bddf777
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py
@@ -444,6 +444,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(timeout=0)
 
     def close(self, timeout=None):