public class SbcListBrokerAdditionsEvent extends SbcEvent
Constructor and Description |
---|
SbcListBrokerAdditionsEvent(SbcContext context,
kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<List<kafka.common.BrokerAdditionDescriptionInternal>> cb) |
Modifier and Type | Method and Description |
---|---|
void |
respondToClient(org.apache.kafka.common.requests.ApiError error,
io.confluent.databalancer.event.SbcEvent.SbcEventHandlerResult result)
This method is invoked when an operation completes (the
SbcEventHandlerResult does not indicate that any resources are needed
to continue. |
public SbcListBrokerAdditionsEvent(SbcContext context, kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<List<kafka.common.BrokerAdditionDescriptionInternal>> cb)
public void respondToClient(org.apache.kafka.common.requests.ApiError error, io.confluent.databalancer.event.SbcEvent.SbcEventHandlerResult result)
SbcEvent
SbcEventHandlerResult
does not indicate that any resources are needed
to continue. Events which need to respond to clients via a client callback will respond here.error
- the ApiError value for success or failure. handleEvent operations which completed normally will have a result of ApiError.NONE.result
- The SbcEventHandlerResult which was returned from SbcEvent.handleEvent()
}.