Skip to content

Commit 573611b

Browse files
authored
Manual addition of old OffsetCommitRequest field (#2743)
1 parent d02b054 commit 573611b

2 files changed

Lines changed: 3 additions & 0 deletions

File tree

kafka/protocol/new/schemas/resources/OffsetCommitRequest.json

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,8 @@
6262
"about": "The message offset to be committed." },
6363
{ "name": "CommittedLeaderEpoch", "type": "int32", "versions": "6+", "default": "-1", "ignorable": true,
6464
"about": "The leader epoch of this partition." },
65+
{ "name": "CommitTimestamp", "type": "int64", "versions": "1", "default": "-1",
66+
"about": "The timestamp of the commit." },
6567
{ "name": "CommittedMetadata", "type": "string", "versions": "0+", "nullableVersions": "0+",
6668
"about": "Any associated metadata the client wants to keep." }
6769
]}

test/protocol/new/consumer/test_new_group.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -294,6 +294,7 @@ def test_offset_commit_request_roundtrip(version):
294294
partition_index=0,
295295
committed_offset=100,
296296
committed_leader_epoch=1 if version >= 6 else -1,
297+
commit_timestamp=1 if version == 1 else -1,
297298
committed_metadata="meta"
298299
)
299300
]

0 commit comments

Comments
 (0)