change request metadata error to warning (#1009)

Co-authored-by: Denis Otkidach <[email protected]>
aio-libs · May 23, 2024 · 14aa358 · 14aa358
1 parent c10fed0
commit 14aa358
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/aiokafka/client.py b/aiokafka/client.py
@@ -332,7 +332,7 @@ async def _metadata_update(self, cluster_metadata, topics):
             try:
                 metadata = await conn.send(metadata_request)
             except (KafkaError, asyncio.TimeoutError) as err:
-                log.error(
+                log.warning(
                     "Unable to request metadata from node with id %s: %r", node_id, err
                 )
                 continue