public class DiskFailureDetector
extends java.lang.Object
implements java.lang.Runnable
Constructor and Description |
---|
DiskFailureDetector(KafkaCruiseControlConfig config,
LoadMonitor loadMonitor,
org.apache.kafka.clients.admin.ConfluentAdmin adminClient,
java.util.Queue<Anomaly> anomalies,
org.apache.kafka.common.utils.Time time,
KafkaCruiseControl kafkaCruiseControl,
java.util.List<java.lang.String> selfHealingGoals) |
Modifier and Type | Method and Description |
---|---|
void |
run() |
public DiskFailureDetector(KafkaCruiseControlConfig config, LoadMonitor loadMonitor, org.apache.kafka.clients.admin.ConfluentAdmin adminClient, java.util.Queue<Anomaly> anomalies, org.apache.kafka.common.utils.Time time, KafkaCruiseControl kafkaCruiseControl, java.util.List<java.lang.String> selfHealingGoals)