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

KAFKA-17276; replicaDirectoryId for Fetch and FetchSnapshot should be ignorable (#16819) 

The replicaDirectoryId field for FetchRequest and FetchSnapshotRequest should be ignorable. This allows data objects with the directory id to be serialized to any version of the requests.

Reviewers: José Armando García Sancio <jsancio@apache.org>, Chia-Ping Tsai <chia7712@apache.org>
This commit is contained in:
Ken Huang 2024-08-08 08:53:15 +08:00 committed by GitHub
parent b9099301fb
commit 786d2c9975
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
clients/src/main/resources/common/message/FetchRequest.json
View File

@ -103,7 +103,7 @@
"about": "The earliest available offset of the follower replica. The field is only used when the request is sent by the follower."}, "about": "The earliest available offset of the follower replica. The field is only used when the request is sent by the follower."},
{ "name": "PartitionMaxBytes", "type": "int32", "versions": "0+", { "name": "PartitionMaxBytes", "type": "int32", "versions": "0+",
"about": "The maximum bytes to fetch from this partition. See KIP-74 for cases where this limit may not be honored." }, "about": "The maximum bytes to fetch from this partition. See KIP-74 for cases where this limit may not be honored." },
{ "name": "ReplicaDirectoryId", "type": "uuid", "versions": "17+", "taggedVersions": "17+", "tag": 0, { "name": "ReplicaDirectoryId", "type": "uuid", "versions": "17+", "taggedVersions": "17+", "tag": 0, "ignorable": true,
"about": "The directory id of the follower fetching" } "about": "The directory id of the follower fetching" }
]} ]}
]}, ]},

2
clients/src/main/resources/common/message/FetchSnapshotRequest.json
View File

@ -46,7 +46,7 @@
}, },
{ "name": "Position", "type": "int64", "versions": "0+", { "name": "Position", "type": "int64", "versions": "0+",
"about": "The byte position within the snapshot to start fetching from" }, "about": "The byte position within the snapshot to start fetching from" },
{ "name": "ReplicaDirectoryId", "type": "uuid", "versions": "1+", "taggedVersions": "1+", "tag": 0, { "name": "ReplicaDirectoryId", "type": "uuid", "versions": "1+", "taggedVersions": "1+", "tag": 0, "ignorable": true,
"about": "The directory id of the follower fetching" } "about": "The directory id of the follower fetching" }
] ]
} }