Constructor and Description |
---|
BrokerRemovalTask(String taskId,
KafkaCruiseControlContext context,
boolean shouldShutdown,
Map<Integer,Optional<Long>> brokersToRemoveAndEpochs,
BalanceOpExecutionCompletionCallback executionCompletionCallback,
BrokerRemovalCallback progressCallback) |
Modifier and Type | Method and Description |
---|---|
BrokerRemovalFuture |
brokerRemovalFuture() |
void |
run() |
String |
taskId() |
public BrokerRemovalTask(String taskId, KafkaCruiseControlContext context, boolean shouldShutdown, Map<Integer,Optional<Long>> brokersToRemoveAndEpochs, @Nonnull BalanceOpExecutionCompletionCallback executionCompletionCallback, @Nonnull BrokerRemovalCallback progressCallback)