Skip to content

Commit 0720a52

Browse files
garnaudGuillaume Arnaud
and
Guillaume Arnaud
authored
Fix maximum version to send an OffsetFetchRequest (#2563)
Co-authored-by: Guillaume Arnaud <[email protected]>
1 parent d214321 commit 0720a52

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka/admin/client.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -1496,7 +1496,7 @@ def _list_consumer_group_offsets_send_request(self, group_id,
14961496
A message future
14971497
"""
14981498
version = self._client.api_version(OffsetFetchRequest, max_version=5)
1499-
if version <= 3:
1499+
if version <= 5:
15001500
if partitions is None:
15011501
if version <= 1:
15021502
raise ValueError(

0 commit comments

Comments
 (0)