From eb941ee47d04c27b5ae0b2a80bf43f07e5792592 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Fri, 9 Mar 2018 17:16:56 -0500 Subject: Connection logging cleanups (#1432) --- kafka/conn.py | 9 +++++---- 1 file 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) -- cgit v1.2.1