Skip to content

Commit 8420d76

Browse files
gioeleGabriel Tincu
authored andcommitted
producer/kafka: Disable logging during object destruction (dpkp#2043)
1 parent fecedbe commit 8420d76

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

kafka/producer/kafka.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -449,6 +449,14 @@ def _unregister_cleanup(self):
449449
self._cleanup = None
450450

451451
def __del__(self):
452+
# Disable logger during destruction to avoid touching dangling references
453+
class NullLogger(object):
454+
def __getattr__(self, name):
455+
return lambda *args: None
456+
457+
global log
458+
log = NullLogger()
459+
452460
self.close()
453461

454462
def close(self, timeout=None):

0 commit comments

Comments
 (0)