ControllerEvent

ControllerEvent is the contract of the events in the lifecycle of KafkaController (state machine) that trigger state change.

ControllerEvent events are managed by ControllerEventManager.

Table 1. ControllerEvent Contract
Method	Description
`state`	`state: ControllerState` Requested ControllerState of the ControllerEventManager (while processing a controller event)

Table 2. ControllerEvents
ControllerEvent	ControllerState	Description
AutoPreferredReplicaLeaderElection	AutoLeaderBalance
BrokerChange	BrokerChange
BrokerModifications	BrokerChange
ControlledShutdown	ControlledShutdown
ControllerChange	ControllerChange
Expire	ControllerChange
IsrChangeNotification	IsrChange	Emitted when the ZNodeChildChangeHandler has been notified about the znode child change
LeaderAndIsrResponseReceived	LeaderAndIsrResponseReceived
LogDirEventNotification	LogDirChange
PartitionModifications	TopicChange	Emitted when one of the ZNodeChangeHandler has been notified about the znode change
PartitionReassignment	PartitionReassignment
PartitionReassignmentIsrChange	PartitionReassignment
PreferredReplicaLeaderElection	ManualLeaderBalance
Reelect	ControllerChange
RegisterBrokerAndReelect	ControllerChange
ShutdownEventThread	ControllerShutdown
Startup	ControllerChange
TopicChange	TopicChange
TopicDeletion	TopicDeletion
TopicDeletionStopReplicaResponseReceived	TopicDeletion
TopicUncleanLeaderElectionEnable	TopicUncleanLeaderElectionEnable
UncleanLeaderElectionEnable	UncleanLeaderElectionEnable	Emitted when `KafkaController` is requested to enableDefaultUncleanLeaderElection

Note	`ControllerEvent` is a Scala sealed trait and so all the possible controller events are in a single compilation unit (i.e. a file).

results matching ""