Skip to content

AbstractControlRequest

AbstractControlRequest is an extension of the AbstractRequest abstraction for controller requests that KafkaController uses to propage broker and partition state changes to brokers.

Contract

brokerEpoch

long brokerEpoch()

Used when:

controllerEpoch

int controllerEpoch()

Used when:

controllerId

int controllerId()

Used when:

Implementations

Creating Instance

AbstractControlRequest takes the following to be created:

  • ApiKeys
  • Version

Abstract Class

AbstractControlRequest is an abstract class and cannot be created directly. It is created indirectly for the concrete AbstractControlRequests.