From 5e077e7753712fc8c7152f5076dd2587c0c30e0f Mon Sep 17 00:00:00 2001 From: cheterchao <42969446+zcc0077@users.noreply.github.com> Date: Tue, 29 Apr 2025 17:06:40 +0800 Subject: [PATCH] Update group.py fixing error `AttributeError: 'SubscriptionState' object has no attribute 'need_offset_reset'. Did you mean: 'request_offset_reset'?` --- kafka/consumer/group.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index a86ececf4..471ae5cda 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -877,7 +877,7 @@ def seek_to_beginning(self, *partitions): for tp in partitions: log.debug("Seeking to beginning of partition %s", tp) - self._subscription.need_offset_reset(tp, OffsetResetStrategy.EARLIEST) + self._subscription.request_offset_reset(tp, OffsetResetStrategy.EARLIEST) self._iterator = None def seek_to_end(self, *partitions): @@ -902,7 +902,7 @@ def seek_to_end(self, *partitions): for tp in partitions: log.debug("Seeking to end of partition %s", tp) - self._subscription.need_offset_reset(tp, OffsetResetStrategy.LATEST) + self._subscription.request_offset_reset(tp, OffsetResetStrategy.LATEST) self._iterator = None def subscribe(self, topics=(), pattern=None, listener=None):