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,
UpdatableSbcGoalsConfig updatableSbcGoalsConfig,
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.
|
Map<Integer,Long> |
failedBrokers()
Package-private for testing
This function is not thread-safe and should not be used otherwise.
|
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, UpdatableSbcGoalsConfig updatableSbcGoalsConfig, ApiStatePersistenceStore persistenceStore)
public Map<Integer,Long> failedBrokers()
public void doWork()
doWork
in class kafka.utils.ShutdownableThread