diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py
index 1f78c89cc..bd891c97a 100644
--- a/kafka/producer/kafka.py
+++ b/kafka/producer/kafka.py
@@ -371,7 +371,7 @@ def _cleanup_factory(self):
         _self = weakref.proxy(self)
         def wrapper():
             try:
-                _self.close()
+                _self.close(timeout=0)
             except (ReferenceError, AttributeError):
                 pass
         return wrapper