ControllerEvent

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

ControllerEvent events are managed by ControllerEventManager.

Table 1. ControllerEvent Contract
Method Description

state

state: ControllerState

The requested ControllerState of the ControllerEventManager (that ControllerEventThread sets while processing the controller event)

process

process(): Unit

The action to execute when ControllerEventThread is requested to process the 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

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 ""

    No results matching ""