ControllerEventProcessor

ControllerEventProcessor is the abstraction of processors that can process and preempt controller events.

Table 1. ControllerEventProcessor Contract
Method Description

preempt

preempt(
  event: ControllerEvent): Unit

Preempts a controller event

Used exclusively when QueuedEvent is requested to preempt a ControllerEventProcessor

process

process(
  event: ControllerEvent): Unit

Processes a controller event

Used exclusively when QueuedEvent is requested to process a ControllerEventProcessor

Note
KafkaController is the default and only known implementation of the ControllerEventProcessor Contract in Apache Kafka.

results matching ""

    No results matching ""