Page History

git diff upstream/trunk clients/src/main/resources/common/message/EndQuorumEpochResponse.json
diff --git a/clients/src/main/resources/common/message/EndQuorumEpochResponse.json b/clients/src/main/resources/common/message/EndQuorumEpochResponse.json
index cd23247045..0d5d61b7e7 100644
--- a/clients/src/main/resources/common/message/EndQuorumEpochResponse.json
+++ b/clients/src/main/resources/common/message/EndQuorumEpochResponse.json
@@ -17,8 +17,8 @@
   "apiKey": 54,
   "type": "uuidresponse",
 "versions": "14+", "nullableVersionsname": "14+EndQuorumEpochResponse", "default": "null",
       
-   "aboutvalidVersions": "The replica generated UUID. null otherwise." }0",
        ...
      ]}
    ]}
  ]
}

{
  "apiKey": 1,
  "abouttype": "Therequest",
 ID of the current leader or -1 if the leader is unknown."},
       "listeners": ["zkBroker", "broker", "controller"],
  "name": "FetchRequest",
  "validVersions": "0-14",
  "flexibleVersions": "12+",
  "fields": [
    { "name": "LeaderEpochClusterId", "type": "int32string", "versions": "12+", "nullableVersions": "12+", "default": "-1null",
 "taggedVersions": "12+", "tag": 0, "ignorable": true,
      "about": "The latestclusterId if known leader epoch". This is used to validate metadata fetches prior to broker registration." },
          { "name": "EndPointReplicaId", "type": "Endpointint32", "versions": "140+",
     "entityType": "brokerId",
       "about": "The endpointreplica thatID canof bethe usedfollower, toof communicate-1 withif thethis leader", "fields": [
   request is from a consumer." },
     ...
    { "name": "HostTopics", "type": "string[]FetchTopic", "versions": "140+",
              "about": "The topics hostnameto fetch." },
   "fields": [
         { "name": "PortTopic", "type": "uint16string", "versions": "14+0-12",
 "entityType": "topicName", "ignorable": true,
          "about": "The port." }
          ]}name of the topic to fetch." },
      {  ]},
        ...
"name": "TopicId", "type": "uuid", "versions": "13+", "ignorable": true,
        ]}
"about": "The unique topic ID"},
      ]}
  ]
}

{
  "apiKey": 1,
  clusterId if known, this is used to validate metadata fetches prior to broker
   registration" },
    { "name": "ReplicaId", "type": "int32response",
  "versionsname": "0+FetchResponse",
  "defaultvalidVersions": "0-114",
  "entityTypeflexibleVersions": "brokerId12+",
      "aboutfields": "The[
 replica ID of the follower" }, ...
    { "name": "MaxBytesResponses", "type": "int32[]FetchableTopicResponse", "versions": "0+", "default": "0x7fffffff",
      "about": "The maximum bytes to fetch from all of the snapshots" },
response topics.", "fields": [
      { "name": "TopicsTopic", "type": "[]TopicSnapshotstring", "versions": "0+-12", "ignorable": true, "entityType": "topicName",
        "about": "The topicstopic to fetch", "fields": [name." },
      { "name": "NameTopicId", "type": "stringuuid", "versions": "013+", "entityTypeignorable": "topicName",
        true, "about": "The name ofunique the topic to fetchID" },
      { "name": "Partitions", "type": "[]PartitionSnapshotPartitionData", "versions": "0+",
        "about": "The topic partitions to fetch.", "fields": [
        { ...
        { "name": "PartitionCurrentLeader", "type": "int32CurrentLeader",
          "versions": "012+",
 "taggedVersions": "12+",        "about"tag": 1, "fields": "The[
 partition index" },
        { "name": "ReplicaUuidLeaderId", "type": "uuidint32", "versions": "112+", "default": "-1", "entityType": "nullbrokerId",
            "about": "The replica UUID of the follower" }, 
ID of the current leader or -1 if the leader is unknown."},
          { "name": "CurrentLeaderEpochLeaderEpoch", "type": "int32", "versions": "0+"12+", "default": "-1",
            "about": "The current leader epoch of the partition, -1 for unknownlatest known leader epoch" },
             { "name": "SnapshotIdEndPoint", "type": "SnapshotIdEndpoint", "versions": "014+",
            "about": "The snapshotendpoint that endOffsetcan andbe epochused to fetchcommunicate with the leader", "fields": [
            { "name": "EndOffsetHost", "type": "int64string", "versions": "014+" },
          {  "name": "Epoch", "typeabout": "int32",The hostname."versions": "0+" },
        ]},
        { "name": "PositionPort", "type": "int64uint16", "versions": "014+",
              "about": "The port." }
 byte position within the snapshot to start fetching from" ]}
        ]},
    ]}
  ]
}

{
  "apiKey": 59,
  "type": "request",
  "listeners": ["controller"],
  "name": "FetchSnapshotRequest",
  "validVersions": "0-1",
  "flexibleVersions": "0+",
  

{
  "apiKey": 59,
  "type": "response",
  "name": "FetchSnapshotResponse",
  "validVersions": "0-1",
  "flexibleVersions": "0+",
  "fields": [
    { "name": "ThrottleTimeMs", "type": "int32", "versions": "0+", "ignorable": true,
      "about": "The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota." },
    { "name": "ErrorCode", "type": "int16", "versions": "0+", "ignorable": false,
      "about": "The top level response error code." },
    { "name": "Topics", "type": "[]TopicSnapshot", "versions": "0+",
      "about": "The topics to fetch.", "fields": [
      { "name": "Name", "type": "string", "versions": "0+", "entityType": "topicName",
        "about": "The name of the topic to fetch." },
      { "name": "Partitions", "type": "[]PartitionSnapshot", "versions": "0+",
        "about": "The partitions to fetch.", "fields": [
        { "name": "Index", "type": "int32", "versions": "0+",
          "about": "The partition index." },
        { "name": "ErrorCode", "type": "int16", "versions": "0+",
          "about": "The error code, or 0 if there was no fetch error." },
        { "name": "SnapshotId", "type": "SnapshotId", "versions": "0+",
          "about": "The snapshot endOffset and epoch fetched",
          "fields": [
          { "name": "EndOffset", "type": "int64", "versions": "0+" },
          { "name": "Epoch", "type": "int32", "versions": "0+" }
        ]},
        { "name": "CurrentLeader", "type": "CurrentLeader",
          "versions": "0+", "taggedVersions": "0+", "tag": 0, "fields": [
          { "name": "LeaderIdClusterId", "type": "int32string", "versions": "0+", "entityTypenullableVersions": "brokerId0+",
 "default": "null", "taggedVersions": "0+", "tag": 0,
      "about": "The ID of the current leader or -1 if the leader is unknown."},clusterId if known, this is used to validate metadata fetches prior to broker
   registration" },
      { "name": "LeaderEpochReplicaId", "type": "int32", "versions": "0+",
 "default": "-1",    "entityType": "brokerId",
      "about": "The replica latestID knownof leaderthe epochfollower" },
          { "name": "EndPointMaxBytes", "type": "Endpointint32", "versions": "10+",
     "default": "0x7fffffff",
       "about": "The endpointmaximum thatbytes canto befetch usedfrom toall communicateof with the leadersnapshots", "fields": [
         },
    { "name": "HostTopics", "type": "string[]TopicSnapshot", "versions": "10+",
              "about": "The hostname." },
      topics to fetch", "fields": [
      { "name": "PortName", "type": "uint16string", "versions": "10+",
      "entityType": "topicName",
        "about": "The port." }
          ]name of the topic to fetch" },
        { "name": "SizePartitions", "type": "int64[]PartitionSnapshot", "versions": "0+",
          "about": "The totalpartitions size of the snapshot." },to fetch", "fields": [
        { "name": "PositionPartition", "type": "int64int32", "versions": "0+",
          "about": "The starting byte position within the snapshot included in the Bytes field."  partition index" },
        { "name": "UnalignedRecordsReplicaUuid", "type": "recordsuuid", "versions": "01+",
          "about"default": "Snapshot data in records format which may not be aligned on an offset boundary" }null",
      ]}
    ]}
  ]
}

{
  "apiKey": 59,
  "type": "response",
  "name": "FetchSnapshotResponse",
  "validVersions": "0-1",
  "flexibleVersions": "0+",
  "fields": [

{
  "apiKey": 54,
  "type": "request",
  "listeners": ["controller"],
  "name": "EndQuorumEpochRequest",
  "validVersions": "0-1",
  "flexibleVersions": "1+",
  "fields": [
    { "name": "ClusterId", "type": "string", "versions": "0+",
      "nullableVersions": "0+", "default": "null"},
    { "name": "LeaderId", "type": "int32", "versions": "1+", "entityType": "brokerId",
      "about": "The current leader ID that is resigning." },
    { "name": "VoterIdThrottleTimeMs", "type": "int32", "versions": "10+", "entityTypeignorable": "brokerId"true,
      "about": "The duration in votermilliseconds IDfor ofwhich the receiving replica." }, 
    { "name": "Topics", "type": "[]TopicData", "versions": "0+", "fields": [ request was throttled due to a quota violation, or zero if the request did not violate any quota." },
      { "name": "TopicNameErrorCode", "type": "stringint16", "versions": "0+", "entityTypeignorable": "topicName"false,
        "about": "The topic name top level response error code." },
      { "name": "PartitionsTopics", "type": "[]PartitionDataTopicSnapshot", "versions": "0+", "fields": [
        { "nameabout": "PartitionIndex", "type": "int32"The topics to fetch.", "versionsfields": "0+",[
        {  "aboutname": "The partition index." },
        { "nameName", "type": "VoterUuidstring", "typeversions": "uuid0+", "versionsentityType": "1+topicName",
          "about": "The replica UUIDname of the topic receivingto replicafetch." }, 
        { "name": "LeaderIdPartitions", "type": "int32[]PartitionSnapshot", "versions": "0", "entityType": "brokerId+",
          "about": "The current leader ID that is resigning"},partitions to fetch.", "fields": [
        { "name": "LeaderEpochIndex", "type": "int32", "versions": "0+",
          "about": "The currentpartition epochindex." },
        { "name": "PreferredSuccessorsErrorCode", "type": "[]ReplicaInfoint16", "versions": "0+",
          "about": "AThe sortederror listcode, ofor preferred0 successorsif tothere startwas theno election",fetch error."fields": [},
          { "name": "ReplicaIdSnapshotId", "type": "int32SnapshotId", "versions": "0+", "entityType": "brokerId" },
          { "nameabout": "ReplicaUuid", "type": "uuid", "versions": "1+" }The snapshot endOffset and epoch fetched",
        ]} 
      ]}"fields": [
    ]}
  ]
}