public class DiskUtilizationDetector extends Object implements ResourceUtilizationDetector
ResourceUtilizationAlertType.UNDERUTILIZATION
, we enforce a lower bound on existing
capacity of the cluster, so that there is always at least DiskUtilizationDetectorConfig.getReservedCapacity()
disk space
available. No ResourceUtilizationAlertType.UNDERUTILIZATION
alert will be raised if the existing capacity is
close to DiskUtilizationDetectorConfig.getReservedCapacity()
with some error CAPACITY_EPSILON
.Constructor and Description |
---|
DiskUtilizationDetector(KafkaCruiseControlConfig kccConfig,
org.apache.kafka.common.utils.Time time,
DataBalancerMetricsRegistry metricsRegistry) |
Modifier and Type | Method and Description |
---|---|
void |
detectResourceUtilization(ClusterModel clusterModel) |
int |
getDiskOptimizationMetric() |
void |
resetDetectorState() |
public DiskUtilizationDetector(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 getDiskOptimizationMetric()