diff options
| author | Dana Powers <dana.powers@rd.io> | 2018-03-08 13:13:20 -0500 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2018-03-09 13:24:26 -0500 |
| commit | 8bac9bbfb2b81ee1b29b410d551e039207815c2f (patch) | |
| tree | 77cc472457224ee8758f2668ccbcd7aa07c0d566 | |
| parent | 4cbeb2e591447ba25271c4924393e602ba49b324 (diff) | |
| download | kafka-python-8bac9bbfb2b81ee1b29b410d551e039207815c2f.tar.gz | |
Log socket error string with connection errors
| -rw-r--r-- | kafka/conn.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index b0d6029..0ba9c47 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -343,7 +343,8 @@ class BrokerConnection(object): elif ret not in (errno.EINPROGRESS, errno.EALREADY, errno.EWOULDBLOCK, 10022): log.error('Connect attempt to %s returned error %s.' ' Disconnecting.', self, ret) - self.close(Errors.ConnectionError(ret)) + errstr = errno.errorcode.get(ret, 'UNKNOWN') + self.close(Errors.ConnectionError('{} {}'.format(ret, errstr))) # Connection timed out elif time.time() > request_timeout + self.last_attempt: |