public class SbcZkScheduleBrokerRemovalEvent extends SbcAbstractScheduleBrokerRemovalEvent
SbcAbstractScheduleBrokerRemovalEvent.EligibleBrokers
Constructor and Description |
---|
SbcZkScheduleBrokerRemovalEvent(SbcContext context,
List<Integer> brokersToRemove,
boolean shouldShutdown,
kafka.common.TopicsMetadataSnapshot topicsMetadataSnapshot,
kafka.common.AliveBrokersMetadata aliveBrokersMetadata,
kafka.controller.ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback cb) |
public SbcZkScheduleBrokerRemovalEvent(SbcContext context, List<Integer> brokersToRemove, boolean shouldShutdown, kafka.common.TopicsMetadataSnapshot topicsMetadataSnapshot, kafka.common.AliveBrokersMetadata aliveBrokersMetadata, kafka.controller.ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback cb)