Skip to content

Commit 7e6f8b1

Browse files
committed
Debug log if check_version connection attempt fails
1 parent 4b3405d commit 7e6f8b1

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

kafka/client_async.py

+2
Original file line numberDiff line numberDiff line change
@@ -1052,6 +1052,8 @@ def check_version(self, node_id=None, timeout=None, **kwargs):
10521052

10531053
if conn._api_version is not None:
10541054
return conn._api_version
1055+
else:
1056+
log.debug('Failed to identify api_version after connection attempt to %s', conn)
10551057

10561058
# Timeout
10571059
else:

0 commit comments

Comments
 (0)