We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c390f3a commit 36888b9Copy full SHA for 36888b9
kafka/conn.py
@@ -374,7 +374,8 @@ def connect(self):
374
elif ret not in (errno.EINPROGRESS, errno.EALREADY, errno.EWOULDBLOCK, 10022):
375
log.error('Connect attempt to %s returned error %s.'
376
' Disconnecting.', self, ret)
377
- self.close(Errors.ConnectionError(ret))
+ errstr = errno.errorcode.get(ret, 'UNKNOWN')
378
+ self.close(Errors.ConnectionError('{} {}'.format(ret, errstr)))
379
380
# Connection timed out
381
elif time.time() > request_timeout + self.last_attempt:
0 commit comments