...

Status

Current state: Under Discussion Adopted

Discussion thread: here

JIRA:

...

0 - idle
1 - controller change (Startup, ControllerChange, Reelect)
2 - broker change (BrokerChange)
3 - topic creation/change (TopicChange, PartitionModifications)
4 - topic deletion (TopicDeletion, TopicDeletionStopReplicaResult)
5 - partition reassigning reassignment (PartitionReassignment,
PartitionReassignmentIsrChange)
6 - auto leader balancing balance (AutoPreferredReplicaLeaderElection)
7 - manual leader balancing balance (PreferredReplicaLeaderElection)
8 - controlled shutdown (ControlledShutdown)
9 - isr change (IsrChangeNotification)

For each state, there's a timer with the rate and time with 2 exceptions: BrokerChange (currently tracked as LeaderElectionRateAndTimeMs) and ControlledShutdown (tracked via RequestQueueTimeMs for the the ControlledShutdown request).

(21). kafka.controller:type=ControllerStats,name=ControllerChangeRateAndTimeMs
type: timer
value: rate and latency for the controller change state

(42). kafka.controller:type=ControllerStats,name=TopicCreationRateAndTimeMsTopicChangeRateAndTimeMs

type: timer
value: rate and latency for the controller to create new topics

(53). kafka.controller:type=ControllerStats,name=TopicDeletionRateAndTimeMs
type: timer
value: rate and latency for the controller to delete topics

(64). kafka.controller:type=ControllerStats,name=PartitionReassigningRateAndTimeMsPartitionReassignmentRateAndTimeMs
type: timer
value: rate and latency for the controller to reassign partitions

(75). kafka.controller:type=ControllerStats,name=AutoLeaderBalancingRateAndTimeMsAutoLeaderBalanceRateAndTimeMs
type: timer
value: rate and latency for the controller to auto balance the leaders

(86). kafka.controller:type=ControllerStats,name=ManualLeaderBalancingRateAndTimeMsManualLeaderBalanceRateAndTimeMs
type: timer
value: rate and latency for the controller to manually balance the leaders

(97) kafka.controller:type=ControllerStats,name=IsrChangeRateAndTimeMs

...