public class MetricAnomalyDetector
extends java.lang.Object
implements java.lang.Runnable
KafkaMetricAnomalyFinder
identifies a metric anomaly.
An alert will be triggered if one of the goals is not met.Modifier and Type | Field and Description |
---|---|
static java.lang.String |
KAFKA_CRUISE_CONTROL_OBJECT_CONFIG |
Constructor and Description |
---|
MetricAnomalyDetector(KafkaCruiseControlConfig config,
LoadMonitor loadMonitor,
java.util.Queue<Anomaly> anomalies,
KafkaCruiseControl kafkaCruiseControl) |
Modifier and Type | Method and Description |
---|---|
void |
run() |
public static final java.lang.String KAFKA_CRUISE_CONTROL_OBJECT_CONFIG
public MetricAnomalyDetector(KafkaCruiseControlConfig config, LoadMonitor loadMonitor, java.util.Queue<Anomaly> anomalies, KafkaCruiseControl kafkaCruiseControl)