public class BrokerAdditionStateMachine extends StateMachine<BrokerAdditionStateMachine.BrokerAdditionState,BrokerAdditionStateMachine.BrokerAdditionEvent>
Modifier and Type | Class and Description |
---|---|
static class |
BrokerAdditionStateMachine.BrokerAdditionEvent
An #
BalancerOperationEvent that can take place during the broker addition operation |
static class |
BrokerAdditionStateMachine.BrokerAdditionState
All the possible states of the broker addition operation
|
currentState
Constructor and Description |
---|
BrokerAdditionStateMachine(int brokerId) |
Modifier and Type | Method and Description |
---|---|
static org.apache.kafka.clients.admin.BalancerOperationStatus |
convertBrokerAdditionStatus(org.apache.kafka.clients.admin.PartitionReassignmentsStatus partitionReassignmentsStatus)
Converts the specific sub-task status of a broker addition operation to a #
BalancerOperationStatus . |
static boolean |
isStateTerminal(BrokerAdditionStateMachine.BrokerAdditionState state) |
advanceState, isTerminalState
public static boolean isStateTerminal(BrokerAdditionStateMachine.BrokerAdditionState state)
public static org.apache.kafka.clients.admin.BalancerOperationStatus convertBrokerAdditionStatus(org.apache.kafka.clients.admin.PartitionReassignmentsStatus partitionReassignmentsStatus)
BalancerOperationStatus
.
In order of priority:
1. If both statuses are completed, the operation is considered in a SUCCESS status
2. If one of both statuses are canceled or failed, the operation is in a FAILEd status
3. If none of the above hold, then the operation is in an IN_PROGRESS status