From 1e6c3c93fcd812d2cfbec0a478683b6561b207cf Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 7 Mar 2018 15:38:19 -0800 Subject: Log connected as INFO --- kafka/conn.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'kafka/conn.py') 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) -- cgit v1.2.1