@Immutable public static enum BrokerAdditionV2StateMachine.BrokerAdditionV2State extends Enum<BrokerAdditionV2StateMachine.BrokerAdditionV2State> implements BalancerOperationState
BalancerOperationState.BalancerOperationStateCharacteristics
Enum Constant and Description |
---|
CANCELED
The terminal state at which the broker addition operation has been canceled.
|
COMPLETED
The terminal state at which the broker has been added enough replicas to be considered added to the cluster.
|
IN_PROGRESS
The initial state of broker addition, during which self-healing is running to balance the cluster and by extension add replicas to the new broker.
|
Modifier and Type | Method and Description |
---|---|
boolean |
isTerminal()
Returns boolean indicating whether the state is terminal.
|
org.apache.kafka.clients.admin.PartitionReassignmentsStatus |
status()
Returns the #
PartitionReassignmentsStatus for this phase |
static BrokerAdditionV2StateMachine.BrokerAdditionV2State |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static BrokerAdditionV2StateMachine.BrokerAdditionV2State[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
compareTo, equals, getDeclaringClass, hashCode, name, ordinal, toString, valueOf
name
public static final BrokerAdditionV2StateMachine.BrokerAdditionV2State IN_PROGRESS
public static final BrokerAdditionV2StateMachine.BrokerAdditionV2State COMPLETED
public static final BrokerAdditionV2StateMachine.BrokerAdditionV2State CANCELED
public static BrokerAdditionV2StateMachine.BrokerAdditionV2State[] values()
for (BrokerAdditionV2StateMachine.BrokerAdditionV2State c : BrokerAdditionV2StateMachine.BrokerAdditionV2State.values()) System.out.println(c);
public static BrokerAdditionV2StateMachine.BrokerAdditionV2State 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.PartitionReassignmentsStatus status()
PartitionReassignmentsStatus
for this phasepublic boolean isTerminal()
isTerminal
in interface BalancerOperationState