public class BrokerFailureDetector
extends kafka.utils.ShutdownableThread
Thread.State, Thread.UncaughtExceptionHandler
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
BrokerFailureDetector(KafkaCruiseControlConfig config,
org.apache.kafka.clients.admin.Admin adminClient,
LoadMonitor loadMonitor,
Queue<Anomaly> anomalies,
org.apache.kafka.common.utils.Time time,
KafkaCruiseControl kafkaCruiseControl,
List<String> selfHealingGoals,
ApiStatePersistenceStore persistenceStore) |
Modifier and Type | Method and Description |
---|---|
void |
doWork()
This function is called continuously in a loop, till the failure detector
thread is shutdown.
|
void |
notifyDeadBrokers(Set<Integer> deadBrokers) |
void |
notifyNewBrokers(Set<Integer> newBrokers) |
$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, org.apache.kafka.clients.admin.Admin adminClient, LoadMonitor loadMonitor, Queue<Anomaly> anomalies, org.apache.kafka.common.utils.Time time, KafkaCruiseControl kafkaCruiseControl, List<String> selfHealingGoals, ApiStatePersistenceStore persistenceStore)