THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block |
|---|
{
"apiKey": N,
"type": "request",
"name": "FetchQuorumRecordsRequest",
"validVersions": "0",
"fields": [
{"name": "ClusterId", "type": "int32", "versions": "0+"},
{"name": "ReplicaId", "type": "int32", "versions": "0+",
"about": "The ID of the replica sending the request"},
{"name": "LeaderEpoch", "type": "int32", "versions": "0+",
"about": "The current leader epoch"},
{"name": "FetchOffset", "type": "int64", "versions": "0+",
"about": "The next expected offset to be replicated"},
{"name": "FetchEpoch", "type": "int32", "versions": "0+",
"about": "The epoch of the last replicated record"},
{"name": "MaxWaitTimeMs", "type": "int32", "versions": "0+",
"about": "The maximum time to wait for new data to arrive" }
]
} |
Response Schema
| Code Block |
|---|
{
"apiKey": N,
"type": "response",
"name": "FetchQuorumRecordsResponse",
"validVersions": "0",
"fields": [
{"name": "ErrorCode", "type": "int16", "versions": "0+"},
{"name": "LeaderId", "type": "int32", "versions": "0+",
"about": "The ID of the current leader or -1 if the leader is unknown."},
{"name": "LeaderEpoch", "type": "int32", "versions": "0+",
"about": "The latest known leader epoch"}
{"name": "NextFetchOffset", "type": "int64", "versions": "0+",
"about": "If set, this is the offset that the follower should truncate to"},
{"name": "NextFetchOffsetEpoch", "type": "int32", "versions": "0+",
"about": "The epoch of the next offset in case the follower needs to truncate"},
{"name": "Records", "type": "bytes", "versions": "0+",
"about" "The fetched record data"},
{"name": "HighWatermark", "type": "int64", "versions": "0+",
"about": "The current high watermark"},
{"name": "FirstDirtyOffset", "type": "int64", "versions": "0+",
"about": "First dirty offset which allows followers to determine consistent snapshots"},
{"name": "LastCaughtUpTimeMs", "type": "int64", "versions": "0+",
"about" "The last time the follower was caught up with a majority of the voters"}
]
} |
...