KafkaController是通过事件驱动来运转的。
Startup事件
elect过程
onControllerResignation过程
ControllerChange 事件
Reelect 事件
AutoPreferredReplicaLeaderElection 事件
BrokerChange 事件
onReplicasBecomeOffline 过程
ControlledShutdown 事件
IsrChangeNotification 事件
LeaderAndIsrResponseReceived 事件
LogDirEventNotification 事件
PartitionModifications 事件
PartitionReassignment 事件
initiateReassignReplicasForTopicPartition 过程
onPartitionReassignment 过程
PartitionReassignmentIsrChange 事件
PreferredReplicaLeaderElection 事件
TopicChange 事件
TopicDeletion 事件
TopicDeletionStopReplicaResponseReceived 事件