diff options
| -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. |