diff options
| author | Dana Powers <dana.powers@rd.io> | 2018-03-07 15:38:19 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2018-03-09 13:38:32 -0500 |
| commit | 1e6c3c93fcd812d2cfbec0a478683b6561b207cf (patch) | |
| tree | 858c3746d1f1a8104b1998bc6e30e6ab3a46b107 | |
| parent | 8bac9bbfb2b81ee1b29b410d551e039207815c2f (diff) | |
| download | kafka-python-conn_logging_cleanups.tar.gz | |
Log connected as INFOconn_logging_cleanups
| -rw-r--r-- | kafka/conn.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index 0ba9c47..54415a2 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -333,7 +333,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) @@ -362,7 +362,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) @@ -371,7 +371,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) |