From 221c76a25be3cb058393a9efadf4f768d4b96794 Mon Sep 17 00:00:00 2001 From: Eldar Khabibulin Date: Tue, 13 May 2025 11:43:50 +0300 Subject: [PATCH 1/2] await when meta updated --- aiokafka/client.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/aiokafka/client.py b/aiokafka/client.py index 91a3e0ae..422244c5 100644 --- a/aiokafka/client.py +++ b/aiokafka/client.py @@ -476,10 +476,10 @@ async def _get_conn(self, node_id, *, group=ConnectionGroup.DEFAULT, no_hint=Fal if group == ConnectionGroup.DEFAULT: # Connection failures imply that our metadata is stale, so # let's refresh - self.force_metadata_update() + await self.force_metadata_update() return None else: - return self._conns[conn_id] + return self._conns[conn_id] async def ready(self, node_id, *, group=ConnectionGroup.DEFAULT): conn = await self._get_conn(node_id, group=group) From 59dc5ba52994cedf5edf2fd3bc40eb9baa584342 Mon Sep 17 00:00:00 2001 From: Eldar Khabibulin Date: Tue, 13 May 2025 11:51:55 +0300 Subject: [PATCH 2/2] fix misprint --- aiokafka/client.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/aiokafka/client.py b/aiokafka/client.py index 422244c5..3e6b6dd4 100644 --- a/aiokafka/client.py +++ b/aiokafka/client.py @@ -479,7 +479,7 @@ async def _get_conn(self, node_id, *, group=ConnectionGroup.DEFAULT, no_hint=Fal await self.force_metadata_update() return None else: - return self._conns[conn_id] + return self._conns[conn_id] async def ready(self, node_id, *, group=ConnectionGroup.DEFAULT): conn = await self._get_conn(node_id, group=group)