diff --git a/kafka/conn.py b/kafka/conn.py
index b0d602917..54415a2bc 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -333,7 +333,7 @@ def connect(self):
                     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)
@@ -343,7 +343,8 @@ def connect(self):
             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:
@@ -361,7 +362,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: Connection complete.', self)
                     self.state = ConnectionStates.CONNECTED
                 self.config['state_change_callback'](self)
 
@@ -370,7 +371,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: Connection complete.', self)
                     self.state = ConnectionStates.CONNECTED
                     self._reset_reconnect_backoff()
                     self.config['state_change_callback'](self)