public interface BrokerRemovalPhase<T>
KafkaCruiseControl#removeBroker(int, Optional, BalanceOpExecutionCompletionCallback, BrokerRemovalCallback, String)} (int, Optional, BrokerRemovalCallback, String)}
,
BrokerRemovalPhaseExecutor}
Modifier and Type | Method and Description |
---|---|
T |
execute(BrokerRemovalContext context)
Execute the broker removal phase
|
default boolean |
hasSkippedExecution() |
BrokerRemovalStateMachine.BrokerRemovalState |
startState()
Returns the broker removal state to which this state applies.
|
T execute(BrokerRemovalContext context) throws Exception
Exception
- - if anything goes wrong during phase executionBrokerRemovalStateMachine.BrokerRemovalState startState()
BrokerRemovalRestartablePhase
can be in
alwaysExecute mode in which case the return value of this is irrelevant.default boolean hasSkippedExecution()