Skip to content

ControllerEvent

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

ControllerEvent events are managed by ControllerEventManager.

Contract

preempt

preempt(): Unit

Used when:

  • FIXME

ControllerState

state: ControllerState

ControllerState of the ControllerEventManager (while processing controller events)

Used when:

  • FIXME

Implementations

  • AllocateProducerIds
  • AlterPartitionReceived
  • ApiPartitionReassignment
  • AutoPreferredReplicaLeaderElection
  • BrokerChange
  • BrokerModifications
  • ControlledShutdown
  • ControllerChange
  • Expire
  • IsrChangeNotification
  • LeaderAndIsrResponseReceived
  • ListPartitionReassignments
  • LogDirEventNotification
  • MockEvent
  • PartitionModifications
  • PartitionReassignmentIsrChange
  • Reelect
  • RegisterBrokerAndReelect
  • ReplicaLeaderElection
  • ShutdownEventThread
  • Startup
  • TopicChange
  • TopicDeletion
  • TopicDeletionStopReplicaResponseReceived
  • TopicUncleanLeaderElectionEnable
  • UncleanLeaderElectionEnable
  • UpdateFeatures
  • UpdateMetadataResponseReceived
  • ZkPartitionReassignment

Review Me

[[implementations]] .ControllerEvents [cols="1,1,2",options="header",width="100%"] |=== | ControllerEvent | ControllerState | Description

| <> | <> | [[AutoPreferredReplicaLeaderElection]]

| <> | <> | [[BrokerChange]]

| BrokerModifications | <> | [[BrokerModifications]]

| ControlledShutdown | <> | [[ControlledShutdown]]

| ControllerChange | <> | [[ControllerChange]]

| Expire | <> | [[Expire]]

| IsrChangeNotification | <> a| [[IsrChangeNotification]] Emitted when the <> has been notified about the znode child change

| <> | <> | [[LeaderAndIsrResponseReceived]]

| LogDirEventNotification | <> | [[LogDirEventNotification]]

| PartitionModifications | <> | [[PartitionModifications]] Emitted when one of the <> has been notified about the znode change

| PartitionReassignment | <> | [[PartitionReassignment]]

| PartitionReassignmentIsrChange | <> | [[PartitionReassignmentIsrChange]]

| <> | <> | [[PreferredReplicaLeaderElection]]

| <> | <> | [[Reelect]]

| RegisterBrokerAndReelect | <> | [[RegisterBrokerAndReelect]]

| ShutdownEventThread | <> | [[ShutdownEventThread]]

| <> | <> | [[Startup]]

| TopicChange | <> | [[TopicChange]]

| <> | <> | [[TopicDeletion]]

| TopicDeletionStopReplicaResponseReceived | <> | [[TopicDeletionStopReplicaResponseReceived]]

| TopicUncleanLeaderElectionEnable | <> | [[TopicUncleanLeaderElectionEnable]]

| UncleanLeaderElectionEnable | <> | [[UncleanLeaderElectionEnable]] Emitted when KafkaController is requested to <>

|===

NOTE: ControllerEvent is a Scala sealed trait and so all the possible <> are in a single compilation unit (i.e. a file).