public interface BrokerRemovalPhase<T>
KafkaCruiseControl#removeBroker(int, Optional, BalanceOpExecutionCompletionCallback, BrokerRemovalCallback, String)} (int, Optional, BrokerRemovalCallback, String)}
,
BrokerRemovalPhaseExecutor}
Modifier and Type | Method and Description |
---|---|
T |
execute(BrokerRemovalOptions args)
Execute the broker removal phase
|
default boolean |
hasSkippedExecution() |
BrokerRemovalStateMachine.BrokerRemovalState |
startState()
Returns the broker removal state to which this state applies.
|
T execute(BrokerRemovalOptions args) throws java.lang.Exception
java.lang.Exception
- - if anything goes wrong during phase executionBrokerRemovalStateMachine.BrokerRemovalState startState()
default boolean hasSkippedExecution()