From 8f5907af01b102b0ff32cecdc7070ab230da2586 Mon Sep 17 00:00:00 2001
From: drewdogg <drewdogg@users.noreply.github.com>
Date: Thu, 26 May 2022 17:03:16 -0600
Subject: [PATCH] Log connection errors at ERROR level

---
 kafka/conn.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/kafka/conn.py b/kafka/conn.py
index 1f3bc2006..177053f08 100644
--- 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(