ControllerBrokerRequestBatch¶

ControllerBrokerRequestBatch is an AbstractControllerBrokerRequestBatch.

Every time ControllerBrokerRequestBatch is used it is first requested to prepare a new batch (of controller requests) followed by sending them out to brokers.

Creating Instance¶

ControllerBrokerRequestBatch takes the following to be created:

• KafkaConfig
• ControllerChannelManager
• ControllerEventManager
• ControllerContext
• StateChangeLogger

ControllerBrokerRequestBatch is created along with a KafkaController, separately for the following:

• ControllerBrokerRequestBatch
• ZkReplicaStateMachine
• ZkPartitionStateMachine

Sending ControllerEvent¶

sendEvent(
  event: ControllerEvent): Unit

sendEvent is part of the AbstractControllerBrokerRequestBatch abstraction.

sendEvent requests the ControllerEventManager to enqueue the input ControllerEvent.

Sending Request (to Broker)¶

sendRequest(
  brokerId: Int,
  request: AbstractControlRequest.Builder[_ <: AbstractControlRequest],
  callback: AbstractResponse => Unit = null): Unit

sendRequest is part of the AbstractControllerBrokerRequestBatch abstraction.

sendRequest requests the given ControllerChannelManager to send an controller request out to a broker.