From 8ae6442917d32dca35386ee874cf65df24674bea Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?R=C3=B4mulo=20Furtado?= Date: Sun, 15 Apr 2018 20:11:12 -0300 Subject: [PATCH 1/2] chore(conn) call selector before fetch data with recv --- kafka/conn.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/kafka/conn.py b/kafka/conn.py index cafc4b2f8..f3e9f75d6 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -948,10 +948,11 @@ def check_version(self, timeout=2, strict=False): 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(): From b4091a549a2b3ff60613c17ebe213f66b0089646 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?R=C3=B4mulo=20Furtado?= Date: Sun, 15 Apr 2018 20:13:33 -0300 Subject: [PATCH 2/2] chore(conn) remove extra line --- kafka/conn.py | 1 - 1 file changed, 1 deletion(-) diff --git a/kafka/conn.py b/kafka/conn.py index f3e9f75d6..daaa234d5 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -948,7 +948,6 @@ def check_version(self, timeout=2, strict=False): 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():