diff options
| author | Gioele <gioele@users.noreply.github.com> | 2020-09-08 01:36:10 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-09-07 16:36:10 -0700 |
| commit | e4913db244ca4d435d279d3047aef3c1c01ebd51 (patch) | |
| tree | 44ce3cd08344032588d015d0a81dcf2cb907708d | |
| parent | 3a9d8306137e6f1c7481a5ca2c4b27f62cbb5165 (diff) | |
| download | kafka-python-e4913db244ca4d435d279d3047aef3c1c01ebd51.tar.gz | |
producer/kafka: Disable logging during object destruction (#2043)
| -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): |