public class Consumer
extends kafka.utils.ShutdownableThread
Constructor and Description |
---|
Consumer(java.lang.String topic) |
Modifier and Type | Method and Description |
---|---|
void |
doWork() |
boolean |
isInterruptible() |
java.lang.String |
name() |
$lessinit$greater$default$2, awaitShutdown, debug, debug, debug, error, error, error, fatal, fatal, fatal, info, info, info, initiateShutdown, isRunning, kafka$utils$Logging$_setter_$kafka$utils$Logging$$log4jController_$eq, kafka$utils$Logging$_setter_$loggerName_$eq, kafka$utils$Logging$$log4jController, logger, loggerName, logIdent_$eq, logIdent, run, shutdown, swallow, swallowDebug, swallowError, swallowInfo, swallowTrace, swallowWarn, trace, trace, trace, warn, 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 void doWork()
doWork
in class kafka.utils.ShutdownableThread
public java.lang.String name()
name
in class kafka.utils.ShutdownableThread
public boolean isInterruptible()
isInterruptible
in class kafka.utils.ShutdownableThread