From 14aa35878477cd0ad647ede877f10920aa16223c Mon Sep 17 00:00:00 2001 From: oferda4 Date: Thu, 23 May 2024 19:39:40 +0300 Subject: [PATCH] change request metadata error to warning (#1009) Co-authored-by: Denis Otkidach --- aiokafka/client.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/aiokafka/client.py b/aiokafka/client.py index 02949588..4eea5259 100644 --- 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