Always process pending MetadataRequest in conn.check_version

1 files changed, 2 insertions, 2 deletions

diff --git a/kafka/conn.py b/kafka/conn.py
index 24a2b98..005dd7e 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -598,11 +598,11 @@ class BrokerConnection(object):
             # the attempt to write to a disconnected socket should
             # immediately fail and allow us to infer that the prior
             # request was unrecognized
-            self.send(MetadataRequest[0]([]))
+            mr = self.send(MetadataRequest[0]([]))
 
             if self._sock:
                 self._sock.setblocking(True)
-            while not f.is_done:
+            while not (f.is_done and mr.is_done):
                 self.recv()
             if self._sock:
                 self._sock.setblocking(False)