AbstractControlRequest — Base of Controller Requests

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

Table 1. AbstractControlRequests
AbstractControlRequest Description

LeaderAndIsrRequest

StopReplicaRequest

UpdateMetadataRequest

Creating AbstractControlRequest Instance

AbstractControlRequest takes the following to be created:

  • ApiKeys

  • Version

  • Controller ID

  • Controller Epoch

  • Broker Epoch

AbstractControlRequest initializes the internal properties.

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

results matching ""

    No results matching ""