diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-03-09 17:16:56 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-03-09 17:16:56 -0500 |
| commit | eb941ee47d04c27b5ae0b2a80bf43f07e5792592 (patch) | |
| tree | a095d61744520f896631a6bc5f8ae30bfa6e5bfc | |
| parent | 1ffdd5caf7f10fb5372780cb9a5ac4a906cac342 (diff) | |
| download | kafka-python-eb941ee47d04c27b5ae0b2a80bf43f07e5792592.tar.gz | |
Connection logging cleanups (#1432)
| -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) |