Do not block on sender thread join after timeout in producer.close() (dpkp#1974)

Author: dpkp

kafka/producer/kafka.py

@@ -452,7 +452,7 @@ def __getattr__(self, name):
         global log
         log = NullLogger()
 
-        self.close(timeout=0)
+        self.close()
 
     def close(self, timeout=None):
         """Close this producer.
@@ -491,14 +491,10 @@ def close(self, timeout=None):
                     self._sender.join(timeout)
 
         if self._sender is not None and self._sender.is_alive():
-
             log.info("Proceeding to force close the producer since pending"
                      " requests could not be completed within timeout %s.",
                      timeout)
             self._sender.force_close()
-            # Only join the sender thread when not calling from callback.
-            if not invoked_from_callback:
-                self._sender.join()
 
         self._metrics.close()
         try: