public class SbcZkScheduleBrokerRemovalEvent extends SbcAbstractScheduleBrokerRemovalEvent
SbcAbstractScheduleBrokerRemovalEvent.EligibleBrokers
SbcEvent.SbcEventHandlerResult
brokersToRemove
eventContext, LOG
Constructor and Description |
---|
SbcZkScheduleBrokerRemovalEvent(SbcContext context,
List<Integer> brokersToRemove,
boolean shouldShutdown,
kafka.common.TopicsMetadataSnapshot topicsMetadataSnapshot,
kafka.common.AliveBrokersMetadata aliveBrokersMetadata,
kafka.controller.ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback cb) |
Modifier and Type | Method and Description |
---|---|
protected SbcEvent.SbcEventHandlerResult |
handleEvent()
The "business logic" of an SbcEvent.
|
respondToClient, validateAndScheduleRemoval, validateIfBrokersCanBeRemoved
public SbcZkScheduleBrokerRemovalEvent(SbcContext context, List<Integer> brokersToRemove, boolean shouldShutdown, kafka.common.TopicsMetadataSnapshot topicsMetadataSnapshot, kafka.common.AliveBrokersMetadata aliveBrokersMetadata, kafka.controller.ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback cb)
protected SbcEvent.SbcEventHandlerResult handleEvent()
SbcEvent
handleEvent
in class SbcEvent