Page History

...

value: the state the controller is in, i.e. the event that is currently being processed. Some actions like partition reassignment may take a while and include many events (potentially interleaved with other events), but that doesn't change the fact that at most one event is processed at a time.

Valid states (events comprising that state in brackets):

0 - idle
1 - starting controller change (Startup, ControllerChange, Reelect)
2 - resigning
3 - broker change (BrokerChange)
4 3 - topic creation
5 /change (TopicChange, PartitionModifications)
4 - topic deletion (TopicDeletion, TopicDeletionStopReplicaResult)
6 5 - partition reassigning
7 (PartitionReassignment,
PartitionReassignmentIsrChange)
6 - auto leader balancing (AutoPreferredReplicaLeaderElection)
8 7 - manual leader balancing (PreferredReplicaLeaderElection)
9 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).

(2). kafka.controller:type=ControllerStats,name=ControllerStartRateAndTimeMsControllerChangeRateAndTimeMs
type: timer
value: rate and latency for the controller to startchange state

(34). kafka.controller:type=ControllerStats,name=ControllerResignRateAndTimeMsTopicCreationRateAndTimeMs

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

(45). kafka.controller:type=ControllerStats,name=TopicCreationRateAndTimeMsTopicDeletionRateAndTimeMs
type: timer
value: rate and latency for the controller to create new delete topics

(56). kafka.controller:type=ControllerStats,name=TopicDeletionRateAndTimeMsPartitionReassigningRateAndTimeMs
type: timer
value: rate and latency for the controller to delete topicsreassign partitions

(67). kafka.controller:type=ControllerStats,name=PartitionReassigningRateAndTimeMsAutoLeaderBalancingRateAndTimeMs
type: timer
value: rate and latency for the controller to reassign partitionsauto balance the leaders

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

(89) kafka. kafka.controller:type=ControllerStats,name=ManualLeaderBalancingRateAndTimeMsIsrChangeRateAndTimeMs

type: timer
value: rate and latency for the controller to manually balance the leaders

...