public class BrokerAdditionDetector extends Object implements ResourceUtilizationDetector
Modifier and Type | Field and Description |
---|---|
static String |
BROKER_ADDITION_COMPLETION_TIMER_METRIC_NAME |
static String |
BROKER_ADDITION_COMPUTED_MEAN_CPU_GAUGE_METRIC_NAME |
static String |
BROKER_ADDITION_DESIRED_NEW_BROKER_CPU_GAUGE_METRIC_NAME |
static String |
IN_PROGRESS_ADDITIONS_METRIC_NAME |
Constructor and Description |
---|
BrokerAdditionDetector(KafkaCruiseControlConfig kccConfig,
org.apache.kafka.common.utils.Time time,
DataBalancerMetricsRegistry metricsRegistry,
BrokerAdditionV2StateManager brokerAdditionV2StateManager,
KafkaCruiseControlOperationMetricsTracker operationMetricsTracker) |
Modifier and Type | Method and Description |
---|---|
void |
detectResourceUtilization(ClusterModel clusterModel) |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
resetDetectorState
public static final String BROKER_ADDITION_COMPLETION_TIMER_METRIC_NAME
public static final String BROKER_ADDITION_DESIRED_NEW_BROKER_CPU_GAUGE_METRIC_NAME
public static final String BROKER_ADDITION_COMPUTED_MEAN_CPU_GAUGE_METRIC_NAME
public static final String IN_PROGRESS_ADDITIONS_METRIC_NAME
public BrokerAdditionDetector(KafkaCruiseControlConfig kccConfig, org.apache.kafka.common.utils.Time time, DataBalancerMetricsRegistry metricsRegistry, BrokerAdditionV2StateManager brokerAdditionV2StateManager, KafkaCruiseControlOperationMetricsTracker operationMetricsTracker)
public void detectResourceUtilization(ClusterModel clusterModel)
detectResourceUtilization
in interface ResourceUtilizationDetector