From 67bf2e6582fd9c5c7f62bf680f12a5574f78ad95 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Sat, 28 Dec 2019 15:23:21 -0800
Subject: Retain blocking on sender thread for del(producer)

---
 kafka/producer/kafka.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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.
-- 
cgit v1.2.1