dpkp
diff --git a/‎kafka/conn.py
Copy file name to clipboardExpand all lines: kafka/conn.py
+1-1Lines changed: 1 addition & 1 deletion b/‎kafka/conn.py
Copy file name to clipboardExpand all lines: kafka/conn.py
+1-1Lines changed: 1 addition & 1 deletion
@@ -769,7 +769,7 @@ def _update_reconnect_backoff(self):
             log.debug('%s: reconnect backoff %s after %s failures', self, self._reconnect_backoff, self._failures)
 
     def _close_socket(self):
-        if self._sock:
+        if hasattr(self, '_sock') and self._sock is not None:
             self._sock.close()
             self._sock = None