root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Change snapshot epoch type to int32 in schema. (#20016) (#20018) 

* `SnapshotEpoch` type in `ShareSnapshotValue.json` and
`ShareUpdateValue.json` is currently
`uint16` which might overflow under heavy traffic.
* To be consistent with other epochs, this PR updates the type to
`int32`.

backport from trunk (cb809e2574)

Reviewers: Andrew Schofield <aschofield@confluent.io>
This commit is contained in:
Sushant Mahajan 2025-06-23 18:53:06 +05:30 committed by GitHub
parent 7b6ef4d322
commit 150412d7f7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
share-coordinator/src/main/resources/common/message/ShareSnapshotValue.json
View File

@ -20,7 +20,7 @@
"validVersions": "0", "validVersions": "0",
"flexibleVersions": "0+", "flexibleVersions": "0+",
"fields": [ "fields": [
{ "name": "SnapshotEpoch", "type": "uint16", "versions": "0+", { "name": "SnapshotEpoch", "type": "int32", "versions": "0+",
"about": "The snapshot epoch." }, "about": "The snapshot epoch." },
{ "name": "StateEpoch", "type": "int32", "versions": "0+", { "name": "StateEpoch", "type": "int32", "versions": "0+",
"about": "The state epoch for this share-partition." }, "about": "The state epoch for this share-partition." },

2
share-coordinator/src/main/resources/common/message/ShareUpdateValue.json
View File

@ -20,7 +20,7 @@
"validVersions": "0", "validVersions": "0",
"flexibleVersions": "0+", "flexibleVersions": "0+",
"fields": [ "fields": [
{ "name": "SnapshotEpoch", "type": "uint16", "versions": "0+", { "name": "SnapshotEpoch", "type": "int32", "versions": "0+",
"about": "The snapshot epoch." }, "about": "The snapshot epoch." },
{ "name": "LeaderEpoch", "type": "int32", "versions": "0+", { "name": "LeaderEpoch", "type": "int32", "versions": "0+",
"about": "The leader epoch of the share-partition." }, "about": "The leader epoch of the share-partition." },