Skip to content

Commit 827dee2

Browse files
authored
Fix possible AttribueError during conn._close_socket (#1776)
1 parent 51313d7 commit 827dee2

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
@@ -769,7 +769,7 @@ def _update_reconnect_backoff(self):
769769
log.debug('%s: reconnect backoff %s after %s failures', self, self._reconnect_backoff, self._failures)
770770

771771
def _close_socket(self):
772-
if self._sock:
772+
if hasattr(self, '_sock') and self._sock is not None:
773773
self._sock.close()
774774
self._sock = None
775775

0 commit comments

Comments
 (0)