Skip to content

Commit d90cf22

Browse files
authored
Close leaked selector in version check (#1425)
1 parent ce96752 commit d90cf22

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

kafka/conn.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -928,6 +928,7 @@ def connect():
928928
for response, future in self.recv():
929929
future.success(response)
930930
selector.select(1)
931+
selector.close()
931932

932933
if f.succeeded():
933934
if isinstance(request, ApiVersionRequest[0]):

0 commit comments

Comments
 (0)