public class KafkaMetricAnomaly extends java.lang.Object implements MetricAnomaly<BrokerEntity>
Constructor and Description |
---|
KafkaMetricAnomaly(KafkaCruiseControl kafkaCruiseControl,
java.lang.String description,
BrokerEntity brokerEntity,
java.lang.Short metricId,
java.util.List<java.lang.Long> windows)
Kafka Metric anomaly
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
anomalyId() |
java.lang.String |
description()
Get the anomaly description.
|
BrokerEntity |
entity()
Get the broker entity with metric anomaly.
|
boolean |
fix()
Fix the anomaly with the system.
|
java.lang.Short |
metricId()
Get the metric Id caused the metric anomaly.
|
java.lang.String |
toString() |
java.util.List<java.lang.Long> |
windows()
Get a list of windows for which a metric anomaly was observed.
|
public KafkaMetricAnomaly(KafkaCruiseControl kafkaCruiseControl, java.lang.String description, BrokerEntity brokerEntity, java.lang.Short metricId, java.util.List<java.lang.Long> windows)
kafkaCruiseControl
- The Kafka Cruise Control instance.description
- The details on why this is identified as an anomaly.brokerEntity
- The broker for which the anomaly was identified.metricId
- The metric id for which the anomaly was identified.windows
- Thw list of windows tha the anomaly was observed.public java.util.List<java.lang.Long> windows()
windows
in interface MetricAnomaly<BrokerEntity>
public java.lang.String description()
description
in interface MetricAnomaly<BrokerEntity>
public BrokerEntity entity()
entity
in interface MetricAnomaly<BrokerEntity>
public java.lang.Short metricId()
metricId
in interface MetricAnomaly<BrokerEntity>
public java.lang.String anomalyId()
public boolean fix() throws KafkaCruiseControlException
fix
in interface Anomaly
KafkaCruiseControlException
public java.lang.String toString()
toString
in class java.lang.Object