From e81a0070b86df8264ee74b70d84d67f7309acb21 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 18 Mar 2026 16:31:33 -0700 Subject: [PATCH] Manual addition of old OffsetCommitRequest field --- kafka/protocol/new/schemas/resources/OffsetCommitRequest.json | 2 ++ test/protocol/new/consumer/test_new_group.py | 1 + 2 files changed, 3 insertions(+) diff --git a/kafka/protocol/new/schemas/resources/OffsetCommitRequest.json b/kafka/protocol/new/schemas/resources/OffsetCommitRequest.json index 348ed2b90..013142d2b 100644 --- a/kafka/protocol/new/schemas/resources/OffsetCommitRequest.json +++ b/kafka/protocol/new/schemas/resources/OffsetCommitRequest.json @@ -62,6 +62,8 @@ "about": "The message offset to be committed." }, { "name": "CommittedLeaderEpoch", "type": "int32", "versions": "6+", "default": "-1", "ignorable": true, "about": "The leader epoch of this partition." }, + { "name": "CommitTimestamp", "type": "int64", "versions": "1", "default": "-1", + "about": "The timestamp of the commit." }, { "name": "CommittedMetadata", "type": "string", "versions": "0+", "nullableVersions": "0+", "about": "Any associated metadata the client wants to keep." } ]} diff --git a/test/protocol/new/consumer/test_new_group.py b/test/protocol/new/consumer/test_new_group.py index e4aa909bb..bfc25655a 100644 --- a/test/protocol/new/consumer/test_new_group.py +++ b/test/protocol/new/consumer/test_new_group.py @@ -293,6 +293,7 @@ def test_offset_commit_request_roundtrip(version): partition_index=0, committed_offset=100, committed_leader_epoch=1 if version >= 6 else -1, + commit_timestamp=1 if version == 1 else -1, committed_metadata="meta" ) ]