diff --git a/kafka/conn.py b/kafka/conn.py index 247cff6..1408a99 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -274,7 +274,7 @@ class BrokerConnection(object): self.afi = self._sock.family self._gai = None except socket.error as err: - ret = err + ret = err.errno # Connection succeeded if not ret or ret == errno.EISCONN: