Break KafkaClient poll if closed

52388fa · Nov 20, 2018 · 2c77c8d · 2c77c8d
1 parent 6675462
commit 2c77c8d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/kafka/client_async.py b/kafka/client_async.py
@@ -551,6 +551,8 @@ def poll(self, timeout_ms=None, future=None):
         responses = []
         while True:
             with self._lock:
+                if self._closed:
+                    break
 
                 # Attempt to complete pending connections
                 for node_id in list(self._connecting):