ControllerBrokerRequestBatch is an AbstractControllerBrokerRequestBatch.
ControllerBrokerRequestBatch takes the following to be created:
ControllerBrokerRequestBatch is created along with a KafkaController, separately for the following:
sendEvent( event: ControllerEvent): Unit
sendEvent is part of the AbstractControllerBrokerRequestBatch abstraction.
Sending Request (to Broker)¶
sendRequest( brokerId: Int, request: AbstractControlRequest.Builder[_ <: AbstractControlRequest], callback: AbstractResponse => Unit = null): Unit
sendRequest is part of the AbstractControllerBrokerRequestBatch abstraction.