Log connection errors at ERROR level (#139)

Co-authored-by: drewdogg <[email protected]>
wbarnha · Mar 12, 2024 · eb6fd9b · eb6fd9b
1 parent 54cbd63
commit eb6fd9b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/conn.py b/kafka/conn.py
@@ -916,7 +916,7 @@ def close(self, error=None):
         with self._lock:
             if self.state is ConnectionStates.DISCONNECTED:
                 return
-            log.info('%s: Closing connection. %s', self, error or '')
+            log.log(logging.ERROR if error else logging.INFO, '%s: Closing connection. %s', self, error or '')
             self._update_reconnect_backoff()
             self._sasl_auth_future = None
             self._protocol = KafkaProtocol(