diff options
Diffstat (limited to 'kafka/conn.py')
-rw-r--r-- | kafka/conn.py | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index 4bbd744..dae468b 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -373,7 +373,7 @@ class BrokerConnection(object): self.state = ConnectionStates.AUTHENTICATING else: # security_protocol PLAINTEXT - log.debug('%s: Connection complete.', self) + log.info('%s: Connection complete.', self) self.state = ConnectionStates.CONNECTED self._reset_reconnect_backoff() self.config['state_change_callback'](self) @@ -383,7 +383,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: @@ -401,7 +402,7 @@ class BrokerConnection(object): log.debug('%s: initiating SASL authentication', self) self.state = ConnectionStates.AUTHENTICATING else: - log.debug('%s: Connection complete.', self) + log.info('%s: Connection complete.', self) self.state = ConnectionStates.CONNECTED self.config['state_change_callback'](self) @@ -410,7 +411,7 @@ class BrokerConnection(object): if self._try_authenticate(): # _try_authenticate has side-effects: possibly disconnected on socket errors if self.state is ConnectionStates.AUTHENTICATING: - log.debug('%s: Connection complete.', self) + log.info('%s: Connection complete.', self) self.state = ConnectionStates.CONNECTED self._reset_reconnect_backoff() self.config['state_change_callback'](self) |