Skip to content

Commit df77a15

Browse files
romulorosa88manpreet
authored andcommitted
Improve BrokerConnection initialization (dpkp#1475)
1 parent 03488f3 commit df77a15

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka/conn.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -949,9 +949,9 @@ def check_version(self, timeout=2, strict=False):
949949
selector = self.config['selector']()
950950
selector.register(self._sock, selectors.EVENT_READ)
951951
while not (f.is_done and mr.is_done):
952+
selector.select(1)
952953
for response, future in self.recv():
953954
future.success(response)
954-
selector.select(1)
955955
selector.close()
956956

957957
if f.succeeded():

0 commit comments

Comments
 (0)