From 0a2ccba3cb1b8636f615a30821123720773a8dfa Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sat, 10 Nov 2018 12:45:01 -0800 Subject: (Attempt to) Fix deadlock between consumer and heartbeat (#1628) --- kafka/client_async.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) (limited to 'kafka/client_async.py') diff --git a/kafka/client_async.py b/kafka/client_async.py index ccf1e4b..0cb575c 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -571,9 +571,7 @@ class KafkaClient(object): self._poll(timeout) - # called without the lock to avoid deadlock potential - # if handlers need to acquire locks - responses.extend(self._fire_pending_completed_requests()) + responses.extend(self._fire_pending_completed_requests()) # If all we had was a timeout (future is None) - only do one poll # If we do have a future, we keep looping until it is done -- cgit v1.2.1