diff options
| author | Dana Powers <dana.powers@gmail.com> | 2019-12-28 15:23:21 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2019-12-28 15:23:21 -0800 |
| commit | 67bf2e6582fd9c5c7f62bf680f12a5574f78ad95 (patch) | |
| tree | ec1ddc920addee8b1c37353ea07c1003ecd2b9a3 | |
| parent | 126412278f0b2eda9dd255a7c2f6104fb732e30d (diff) | |
| download | kafka-python-issue-1931-logging-producer-deadlock.tar.gz | |
Retain blocking on sender thread for del(producer)issue-1931-logging-producer-deadlock
| -rw-r--r-- | kafka/producer/kafka.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index a63f6a7..d3a531e 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -444,7 +444,7 @@ class KafkaProducer(object): self._cleanup = None def __del__(self): - self.close(timeout=0) + self.close() def close(self, timeout=None): """Close this producer. |