public class BrokerAdditionV1Context extends Object
Modifier and Type | Field and Description |
---|---|
static String |
BROKER_ADDITION_STATE_METRIC_NAME |
Constructor and Description |
---|
BrokerAdditionV1Context(DataBalancerMetricsRegistry dataBalancerMetricsRegistry) |
Modifier and Type | Method and Description |
---|---|
List<kafka.common.BrokerAdditionDescriptionInternal> |
brokerAdditions() |
Set<Integer> |
brokersBeingAdded() |
BrokerAdditionStateManager |
initializeAddition(int brokerId) |
void |
overrideAllPendingBrokerAdditions(BrokerAdditionStateMachine.BrokerAdditionEvent event,
String cause) |
public static final String BROKER_ADDITION_STATE_METRIC_NAME
public BrokerAdditionV1Context(DataBalancerMetricsRegistry dataBalancerMetricsRegistry)
public BrokerAdditionStateManager initializeAddition(int brokerId)
public void overrideAllPendingBrokerAdditions(BrokerAdditionStateMachine.BrokerAdditionEvent event, String cause)
public List<kafka.common.BrokerAdditionDescriptionInternal> brokerAdditions()