Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
"apiKey": 55,
"type": "response",
"name": "DescribeQuorumResponse",
// Version 1 adds LastFetchTimeStamp and LastCaughtUpTimestamp in ReplicaState (KIP-836).
// Version 2 adds ErrorMessage, Nodes, ErrorMessage in PartitionData, ReplicaDirectoryId in ReplicaState (KIP-853).
// Version 3 adds InactiveObservers in PartitionData (KIP-1073).
"validVersions": "0-3",
"flexibleVersions": "0+",
"fields": [
 { "name": "ErrorCode", "type": "int16", "versions": "0+",
   "about": "The top level error code."},
 { "name": "ErrorMessage", "type": "string", "versions": "2+", "nullableVersions": "2+", "ignorable": true,
   "about": "The error message, or null if there was no error." },
 { "name": "Topics", "type": "[]TopicData",
   "versions": "0+", "fields": [
   { "name": "TopicName", "type": "string", "versions": "0+", "entityType": "topicName",
     "about": "The topic name." },
   { "name": "Partitions", "type": "[]PartitionData",
     "versions": "0+", "fields": [
     { "name": "PartitionIndex", "type": "int32", "versions": "0+",
       "about": "The partition index." },
     { "name": "ErrorCode", "type": "int16", "versions": "0+"},
     { "name": "ErrorMessage", "type": "string", "versions": "2+", "nullableVersions": "2+", "ignorable": true,
       "about": "The error message, or null if there was no error." },
     { "name": "LeaderId", "type": "int32", "versions": "0+", "entityType": "brokerId",
       "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": "HighWatermark", "type": "int64", "versions": "0+"},
     { "name": "CurrentVoters", "type": "[]ReplicaState", "versions": "0+" },
     { "name": "Observers", "type": "[]ReplicaState", "versions": "0+",
       "about": "Observers that are actively fetching from the leader"},
     // new added InactiveObservers field
     { "name":  "InactiveObservers", "type": "[]ReplicaState", "versions": "3+", "default": null,   
       "about": "Observers that have not been active for a while"}
   ]}
 ]},
 { "name": "Nodes", "type": "[]Node", "versions": "2+", "fields": [
   { "name": "NodeId", "type": "int32", "versions": "2+",
     "mapKey": true, "entityType": "brokerId", "about": "The ID of the associated node" },
   { "name": "Listeners", "type": "[]Listener",
     "about": "The listeners of this controller", "versions": "2+", "fields": [
     { "name": "Name", "type": "string", "versions": "2+", "mapKey": true,
       "about": "The name of the endpoint" },
     { "name": "Host", "type": "string", "versions": "2+",
       "about": "The hostname" },
     { "name": "Port", "type": "uint16", "versions": "2+",
       "about": "The port" }
   ]}
 ]}
],
"commonStructs": [
 { "name": "ReplicaState", "versions": "0+", "fields": [
   { "name": "ReplicaId", "type": "int32", "versions": "0+", "entityType": "brokerId" },
   { "name": "ReplicaDirectoryId", "type": "uuid", "versions": "2+" },
   { "name": "LogEndOffset", "type": "int64", "versions": "0+",
     "about": "The last known log end offset of the follower or -1 if it is unknown"},
   { "name": "LastFetchTimestamp", "type": "int64", "versions": "1+", "ignorable": true, "default": -1,
     "about": "The last known leader wall clock time when a follower fetched from the leader. This is reported as -1 both for the current leader or if it is unknown for a voter"},
   { "name": "LastCaughtUpTimestamp", "type": "int64", "versions": "1+", "ignorable": true, "default": -1,
     "about": "The leader wall clock appends the time of the offset for which the follower made the most recent fetch request. This is reported as the current time for the leader and -1 if unknown for a voter"}
 ]}
]

...