diff options
| -rw-r--r-- | kafka/producer/kafka.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index dba1801..cde26b0 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -449,6 +449,14 @@ class KafkaProducer(object): 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): |