diff options
| author | guojh <gjhdgm@gmail.com> | 2016-12-18 09:10:42 +0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-12-17 17:10:42 -0800 |
| commit | e8283958e42047a31bc914fe53b2060fa5e4481b (patch) | |
| tree | d64bffe008e8e1e3d9fce6b825f9827e4cdc044f | |
| parent | 103ac7eb11071395fb566495a4c1e0eb62482263 (diff) | |
| download | kafka-python-e8283958e42047a31bc914fe53b2060fa5e4481b.tar.gz | |
Bug fix: ret = err => ret = err.errno (#907)
| -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: |