@Immutable public static enum BrokerRemovalStateMachine.BrokerRemovalState extends Enum<BrokerRemovalStateMachine.BrokerRemovalState> implements BalancerOperationState
BalancerOperationState.BalancerOperationStateCharacteristics
Enum Constant and Description |
---|
BROKER_SHUTDOWN_CANCELED
The terminal state reached when cancellation occurs during broker shutdown.
|
BROKER_SHUTDOWN_FAILED
The terminal state reached when the broker shutdown is canceled.
|
BROKER_SHUTDOWN_INITIATED
The operation state after plan execution completes when shouldShutdown = true.
|
CANCELED
A terminal state indicating that the operation was canceled.
|
EXCLUSION_CANCELED
The terminal state when cancellation occurs while establishing broker replica exclusions.
|
EXCLUSION_FAILED
The terminal state reached when establishing replica exclusion on the broker fails.
|
EXCLUSION_INITIATED
The state after the initial plan validation passes and SBC proceeds to set broker replica exclusion for the brokers being removed.
|
EXCLUSION_REMOVAL_CANCELED
The terminal state reached when a cancellation event occurs during the replica exclusion removal.
|
EXCLUSION_REMOVAL_FAILED
The terminal state reached when replica exclusion removal fails.
|
EXCLUSION_REMOVAL_INITIATED
The operation state after broker shutdown has completed, when broker replica exclusions are being removed.
|
EXCLUSION_REMOVAL_SUCCEEDED
The terminal state reached once broker replica exclusions have been removed.
|
INITIAL_PLAN_COMPUTATION_CANCELED
The terminal state reached when cancellation occurs during initial plan computation.
|
INITIAL_PLAN_COMPUTATION_FAILED
The terminal state reached when the initial plan computation fails.
|
INITIAL_PLAN_COMPUTATION_INITIATED
The starting state of broker removal, when the initial plan computation (serving as validation before exclusion occurs) has not finished.
|
PLAN_COMPUTATION_CANCELED
The terminal state reached when cancellation occurs during the plan computation phase.
|
PLAN_COMPUTATION_FAILED
The terminal state reached when the real plan computation fails.
|
PLAN_COMPUTATION_INITIATED
The state after the broker shutdown succeeds and the real plan computation is happening.
|
PLAN_EXECUTION_CANCELED
The terminal state reached when cancellation occurs during final plan execution.
|
PLAN_EXECUTION_FAILED
The terminal state reached when the final plan execution fails.
|
PLAN_EXECUTION_INITIATED
The state after the plan computation succeeds and plan execution is happening.
|
PLAN_EXECUTION_SUCCEEDED
The terminal state reached when the final plan execution succeeds and the whole broker removal operation is finished.
|
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.admin.BrokerShutdownStatus |
brokerShutdownStatus()
Returns the broker shutdown status for this state.
|
boolean |
isSuccess()
Return a boolean indicating whether the state represents a successful completion of the operation.
|
boolean |
isTerminal()
Returns boolean indicating whether the state is terminal.
|
org.apache.kafka.clients.admin.PartitionReassignmentsStatus |
partitionReassignmentsStatus()
Returns the partitions reassignment status for this state
|
org.apache.kafka.clients.admin.BrokerReplicaExclusionStatus |
replicaExclusionStatus()
Return the exclusion status for this state
|
org.apache.kafka.clients.admin.BalancerOperationStatus |
toBalancerOperationStatus() |
static BrokerRemovalStateMachine.BrokerRemovalState |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static BrokerRemovalStateMachine.BrokerRemovalState[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf
name
public static final BrokerRemovalStateMachine.BrokerRemovalState CANCELED
public static final BrokerRemovalStateMachine.BrokerRemovalState INITIAL_PLAN_COMPUTATION_INITIATED
public static final BrokerRemovalStateMachine.BrokerRemovalState INITIAL_PLAN_COMPUTATION_FAILED
public static final BrokerRemovalStateMachine.BrokerRemovalState INITIAL_PLAN_COMPUTATION_CANCELED
public static final BrokerRemovalStateMachine.BrokerRemovalState EXCLUSION_INITIATED
public static final BrokerRemovalStateMachine.BrokerRemovalState EXCLUSION_FAILED
public static final BrokerRemovalStateMachine.BrokerRemovalState EXCLUSION_CANCELED
public static final BrokerRemovalStateMachine.BrokerRemovalState PLAN_COMPUTATION_INITIATED
public static final BrokerRemovalStateMachine.BrokerRemovalState PLAN_COMPUTATION_FAILED
public static final BrokerRemovalStateMachine.BrokerRemovalState PLAN_COMPUTATION_CANCELED
public static final BrokerRemovalStateMachine.BrokerRemovalState PLAN_EXECUTION_INITIATED
public static final BrokerRemovalStateMachine.BrokerRemovalState PLAN_EXECUTION_CANCELED
public static final BrokerRemovalStateMachine.BrokerRemovalState PLAN_EXECUTION_FAILED
public static final BrokerRemovalStateMachine.BrokerRemovalState PLAN_EXECUTION_SUCCEEDED
public static final BrokerRemovalStateMachine.BrokerRemovalState BROKER_SHUTDOWN_INITIATED
public static final BrokerRemovalStateMachine.BrokerRemovalState BROKER_SHUTDOWN_CANCELED
public static final BrokerRemovalStateMachine.BrokerRemovalState BROKER_SHUTDOWN_FAILED
public static final BrokerRemovalStateMachine.BrokerRemovalState EXCLUSION_REMOVAL_INITIATED
public static final BrokerRemovalStateMachine.BrokerRemovalState EXCLUSION_REMOVAL_FAILED
public static final BrokerRemovalStateMachine.BrokerRemovalState EXCLUSION_REMOVAL_CANCELED
public static final BrokerRemovalStateMachine.BrokerRemovalState EXCLUSION_REMOVAL_SUCCEEDED
public static BrokerRemovalStateMachine.BrokerRemovalState[] values()
for (BrokerRemovalStateMachine.BrokerRemovalState c : BrokerRemovalStateMachine.BrokerRemovalState.values()) System.out.println(c);
public static BrokerRemovalStateMachine.BrokerRemovalState valueOf(String name)
name
- the name of the enum constant to be returned.IllegalArgumentException
- if this enum type has no constant with the specified nameNullPointerException
- if the argument is nullpublic org.apache.kafka.clients.admin.BrokerShutdownStatus brokerShutdownStatus()
public org.apache.kafka.clients.admin.PartitionReassignmentsStatus partitionReassignmentsStatus()
public org.apache.kafka.clients.admin.BrokerReplicaExclusionStatus replicaExclusionStatus()
public boolean isTerminal()
isTerminal
in interface BalancerOperationState
public boolean isSuccess()
public org.apache.kafka.clients.admin.BalancerOperationStatus toBalancerOperationStatus()