From e23676d6c03b87f14ec8992de583f673dc8a1a3e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?R=C3=B4mulo=20Rosa=20Furtado?= Date: Sun, 15 Apr 2018 22:30:21 -0300 Subject: Improve BrokerConnection initialization (#1475) --- kafka/conn.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'kafka/conn.py') diff --git a/kafka/conn.py b/kafka/conn.py index cafc4b2..daaa234 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -949,9 +949,9 @@ class BrokerConnection(object): selector = self.config['selector']() selector.register(self._sock, selectors.EVENT_READ) while not (f.is_done and mr.is_done): + selector.select(1) for response, future in self.recv(): future.success(response) - selector.select(1) selector.close() if f.succeeded(): -- cgit v1.2.1