From b083d18eb62a1a9a522925b7b0588420079dfe65 Mon Sep 17 00:00:00 2001 From: Guillaume Arnaud Date: Mon, 24 Mar 2025 16:13:48 +0100 Subject: [PATCH] Fix maximum version to send an OffsetFetchRequest Max version has been increased to 5 but the method raises an NotImplementedError error due to a wrong condition. --- kafka/admin/client.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/admin/client.py b/kafka/admin/client.py index 171304da0..392687be5 100644 --- a/kafka/admin/client.py +++ b/kafka/admin/client.py @@ -1496,7 +1496,7 @@ def _list_consumer_group_offsets_send_request(self, group_id, A message future """ version = self._client.api_version(OffsetFetchRequest, max_version=5) - if version <= 3: + if version <= 5: if partitions is None: if version <= 1: raise ValueError(