diff options
| -rw-r--r-- | kafka/conn.py | 2 |
1 files changed, 1 insertions, 1 deletions
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: |