From 68d67e455a613ef387a816823747de259241e5f8 Mon Sep 17 00:00:00 2001 From: Konstantin Kholostov Date: Wed, 30 Jul 2025 16:18:36 +0200 Subject: [PATCH] Ensure timeout is checked after each fetch position update in `Consumer.position()` --- kafka/consumer/group.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index dcb322b84..c7ad0f59b 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -781,7 +781,7 @@ def position(self, partition, timeout_ms=None): # batch update fetch positions for any partitions without a valid position if self._update_fetch_positions(timeout_ms=timer.timeout_ms): position = self._subscription.assignment[partition].position - elif timer.expired: + if timer.expired: return None else: return position.offset