Log connected as INFO

Author: Dana Powers

kafka/conn.py

@@ -373,7 +373,7 @@ def connect(self):
                     self.state = ConnectionStates.AUTHENTICATING
                 else:
                     # security_protocol PLAINTEXT
-                    log.debug('%s: Connection complete.', self)
+                    log.info('%s: Connected!', self)
                     self.state = ConnectionStates.CONNECTED
                     self._reset_reconnect_backoff()
                 self.config['state_change_callback'](self)
@@ -402,7 +402,7 @@ def connect(self):
                     log.debug('%s: initiating SASL authentication', self)
                     self.state = ConnectionStates.AUTHENTICATING
                 else:
-                    log.debug('%s: Connection complete.', self)
+                    log.info('%s: Connected!', self)
                     self.state = ConnectionStates.CONNECTED
                 self.config['state_change_callback'](self)
 
@@ -411,7 +411,7 @@ def connect(self):
             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: Connected!', self)
                     self.state = ConnectionStates.CONNECTED
                     self._reset_reconnect_backoff()
                     self.config['state_change_callback'](self)