What is DescribeQuorum?
Shows KRaft controller quorum health via kafka-metadata-quorum.sh --describe. The lagOffset per voter reveals how far behind each follower controller is from the leader. A voter with high lag and not in the ISR may be unable to participate in elections.
| Version | Kafka | Changes |
|---|---|---|
| DescribeQuorumRequest | ||
| v0 | 2.7 | + Topics []TopicData+ TopicName string+ Partitions []PartitionData+ PartitionIndex int32~ Flexible encoding enabled FLEXIBLE |
| v1 | 3.3 | adds additional fields in the response. The request is unchanged (KIP-836). |
| v2 | 3.9 | adds additional fields in the response. The request is unchanged (KIP-853). |
| DescribeQuorumResponse | ||
| v0 | 2.7 | + ErrorCode int16+ Topics []TopicData+ TopicName string+ Partitions []PartitionData+ PartitionIndex int32+ ErrorCode int16+ LeaderId int32+ LeaderEpoch int32+ HighWatermark int64+ CurrentVoters []ReplicaState+ ReplicaId int32+ LogEndOffset int64+ Observers []ReplicaState+ ReplicaId int32+ LogEndOffset int64~ Flexible encoding enabled FLEXIBLE |
| v1 | 3.3 | + LastFetchTimestamp int64+ LastCaughtUpTimestamp int64+ LastFetchTimestamp int64+ LastCaughtUpTimestamp int64adds LastFetchTimeStamp and LastCaughtUpTimestamp in ReplicaState (KIP-836). |
| v2 | 3.9 | + ErrorMessage string+ ErrorMessage string+ ReplicaDirectoryId uuid+ ReplicaDirectoryId uuid+ Nodes []Node+ NodeId int32+ Listeners []Listener+ Name string+ Host string+ Port uint16adds ErrorMessage, Nodes, ErrorMessage in PartitionData, ReplicaDirectoryId in ReplicaState (KIP-853). |