Merge branch 'master' into feature/SASL-Extensions

dpkp · Mar 17, 2024 · 035af5b · 035af5b
2 parents 82fae7a + eb6fd9b
commit 035af5b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/conn.py b/kafka/conn.py
@@ -680,7 +680,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(