KafkaController是通過事件驅動來運轉的。
Startup事件
elect過程
onControllerResignation過程
ControllerChange 事件
Reelect 事件
AutoPreferredReplicaLeaderElection 事件
BrokerChange 事件
onReplicasBecomeOffline 過程
ControlledShutdown 事件
IsrChangeNotification 事件
LeaderAndIsrResponseReceived 事件
LogDirEventNotification 事件
PartitionModifications 事件
PartitionReassignment 事件
initiateReassignReplicasForTopicPartition 過程
onPartitionReassignment 過程
PartitionReassignmentIsrChange 事件
PreferredReplicaLeaderElection 事件
TopicChange 事件
TopicDeletion 事件
TopicDeletionStopReplicaResponseReceived 事件