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(