public class BrokerFailureDetector
extends kafka.utils.ShutdownableThread
Constructor and Description |
---|
BrokerFailureDetector(KafkaCruiseControlConfig config,
scala.Option<org.apache.zookeeper.client.ZKClientConfig> zkClientConfig,
LoadMonitor loadMonitor,
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 |
doWork()
This function is called continuously in a loop, till the failure detector
thread is shutdown.
|
$lessinit$greater$default$2, awaitShutdown, debug, debug, error, error, fatal, fatal, heartbeat, info, info, initiateShutdown, isDebugEnabled, isInterruptible, isRunning, isShutdownComplete, isShutdownInitiated, isThreadFailed, isTraceEnabled, logger, loggerName, logIdent_$eq, logIdent, msgWithLogIdent, name, pause, run, shutdown, trace, trace, warn, warn
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
public BrokerFailureDetector(KafkaCruiseControlConfig config, scala.Option<org.apache.zookeeper.client.ZKClientConfig> zkClientConfig, LoadMonitor loadMonitor, java.util.Queue<Anomaly> anomalies, org.apache.kafka.common.utils.Time time, KafkaCruiseControl kafkaCruiseControl, java.util.List<java.lang.String> selfHealingGoals)