public class CpuUtilizationDetector extends Object implements ResourceUtilizationDetector
ResourceUtilizationCommonConfig.getDurationMs()
and compare
against a threshold.Constructor and Description |
---|
CpuUtilizationDetector(KafkaCruiseControlConfig kccConfig,
org.apache.kafka.common.utils.Time time,
DataBalancerMetricsRegistry metricsRegistry) |
Modifier and Type | Method and Description |
---|---|
void |
detectResourceUtilization(ClusterModel clusterModel) |
int |
getCpuOptimizationMetric() |
void |
resetDetectorState() |
public CpuUtilizationDetector(KafkaCruiseControlConfig kccConfig, org.apache.kafka.common.utils.Time time, DataBalancerMetricsRegistry metricsRegistry)
public void detectResourceUtilization(ClusterModel clusterModel)
detectResourceUtilization
in interface ResourceUtilizationDetector
public void resetDetectorState()
resetDetectorState
in interface ResourceUtilizationDetector
public int getCpuOptimizationMetric()