@Immutable public static enum BrokerRemovalStateMachine.BrokerRemovalState extends java.lang.Enum<BrokerRemovalStateMachine.BrokerRemovalState> implements BalancerOperationState
Enum Constant and Description |
---|
BROKER_SHUTDOWN_CANCELED
The terminal state of when the broker shutdown is canceled.
|
BROKER_SHUTDOWN_FAILED
The terminal state of when the act of shutting down the broker fails.
|
BROKER_SHUTDOWN_INITIATED
The state after the initial plan validation passes and SBK proceeds to shutting down the broker that is being removed.
|
INITIAL_PLAN_COMPUTATION_FAILED
The terminal state of when the initial plan computation fails.
|
INITIAL_PLAN_COMPUTATION_INITIATED
This is the initial state of broker removal, when the first plan (serving as validation pre-shutdown) is yet to be or is being computed.
|
PLAN_COMPUTATION_CANCELED
The terminal state of when the real plan computation is canceled.
|
PLAN_COMPUTATION_FAILED
The terminal state of 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 of when the final plan execution is canceled.
|
PLAN_EXECUTION_FAILED
The terminal state of when the final plan execution fails.
|
PLAN_EXECUTION_INITIATED
The state after the plan computation succeeds and said plan execution is happening.
|
PLAN_EXECUTION_SUCCEEDED
The terminal state of 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.
|
org.apache.kafka.clients.admin.PartitionReassignmentsStatus |
partitionReassignmentsStatus()
Returns the partitions reassignment status for this state
|
static BrokerRemovalStateMachine.BrokerRemovalState |
valueOf(java.lang.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 INITIAL_PLAN_COMPUTATION_FAILED
public static final BrokerRemovalStateMachine.BrokerRemovalState BROKER_SHUTDOWN_FAILED
public static final BrokerRemovalStateMachine.BrokerRemovalState PLAN_COMPUTATION_FAILED
public static final BrokerRemovalStateMachine.BrokerRemovalState PLAN_COMPUTATION_CANCELED
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 PLAN_EXECUTION_INITIATED
public static final BrokerRemovalStateMachine.BrokerRemovalState BROKER_SHUTDOWN_CANCELED
public static final BrokerRemovalStateMachine.BrokerRemovalState PLAN_COMPUTATION_INITIATED
public static final BrokerRemovalStateMachine.BrokerRemovalState BROKER_SHUTDOWN_INITIATED
public static final BrokerRemovalStateMachine.BrokerRemovalState INITIAL_PLAN_COMPUTATION_INITIATED
public static BrokerRemovalStateMachine.BrokerRemovalState[] values()
for (BrokerRemovalStateMachine.BrokerRemovalState c : BrokerRemovalStateMachine.BrokerRemovalState.values()) System.out.println(c);
public static BrokerRemovalStateMachine.BrokerRemovalState valueOf(java.lang.String name)
name
- the name of the enum constant to be returned.java.lang.IllegalArgumentException
- if this enum type has no constant with the specified namejava.lang.NullPointerException
- if the argument is nullpublic org.apache.kafka.clients.admin.BrokerShutdownStatus brokerShutdownStatus()
public org.apache.kafka.clients.admin.PartitionReassignmentsStatus partitionReassignmentsStatus()