AbstractFetcherThread

abstract def buildFetchRequest(partitionMap: Map[TopicAndPartition, PartitionFetchState]): REQ

abstract def fetch(fetchRequest: REQ): Map[TopicAndPartition, PD]

abstract def handleOffsetOutOfRange(topicAndPartition: TopicAndPartition): Long

abstract def handlePartitionsWithErrors(partitions: Iterable[TopicAndPartition]): Unit

abstract def processPartitionData(topicAndPartition: TopicAndPartition, fetchOffset: Long, partitionData: PD): Unit

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

def addPartitions(partitionAndOffsets: Map[TopicAndPartition, Long]): Unit

final def asInstanceOf[T0]: T0

def awaitShutdown(): Unit

After calling initiateShutdown(), use this API to wait until the shutdown is complete

final def checkAccess(): Unit

def clone(): AnyRef

def debug(msg: ⇒ String, e: ⇒ Throwable): Unit

def debug(e: ⇒ Throwable): Any

def debug(msg: ⇒ String): Unit

def delayPartitions(partitions: Iterable[TopicAndPartition], delay: Long): Unit

def doWork(): Unit

This method is repeatedly invoked until the thread shuts down or this method throws an exception

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def error(msg: ⇒ String, e: ⇒ Throwable): Unit

def error(e: ⇒ Throwable): Any

def error(msg: ⇒ String): Unit

def fatal(msg: ⇒ String, e: ⇒ Throwable): Unit

def fatal(e: ⇒ Throwable): Any

def fatal(msg: ⇒ String): Unit

val fetcherLagStats: FetcherLagStats

val fetcherStats: FetcherStats

def finalize(): Unit

final def getClass(): Class[_]

def getContextClassLoader(): ClassLoader

def getId(): Long

final def getName(): String

final def getPriority(): Int

def getStackTrace(): Array[StackTraceElement]

def getState(): State

final def getThreadGroup(): ThreadGroup

def getUncaughtExceptionHandler(): UncaughtExceptionHandler

def hashCode(): Int

def info(msg: ⇒ String, e: ⇒ Throwable): Unit

def info(e: ⇒ Throwable): Any

def info(msg: ⇒ String): Unit

def initiateShutdown(): Boolean

def interrupt(): Unit

final def isAlive(): Boolean

final def isDaemon(): Boolean

final def isInstanceOf[T0]: Boolean

def isInterrupted(): Boolean

val isInterruptible: Boolean

val isRunning: AtomicBoolean

final def join(): Unit

final def join(arg0: Long, arg1: Int): Unit

final def join(arg0: Long): Unit

var logIdent: String

lazy val logger: Logger

val loggerName: String

val name: String

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def partitionCount(): Int

def removePartitions(topicAndPartitions: Set[TopicAndPartition]): Unit

def run(): Unit

def setContextClassLoader(arg0: ClassLoader): Unit

final def setDaemon(arg0: Boolean): Unit

final def setName(arg0: String): Unit

final def setPriority(arg0: Int): Unit

def setUncaughtExceptionHandler(arg0: UncaughtExceptionHandler): Unit

def shutdown(): Unit

def start(): Unit

def swallow(action: ⇒ Unit): Unit

def swallowDebug(action: ⇒ Unit): Unit

def swallowError(action: ⇒ Unit): Unit

def swallowInfo(action: ⇒ Unit): Unit

def swallowTrace(action: ⇒ Unit): Unit

def swallowWarn(action: ⇒ Unit): Unit

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

def trace(msg: ⇒ String, e: ⇒ Throwable): Unit

def trace(e: ⇒ Throwable): Any

def trace(msg: ⇒ String): Unit

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

def warn(msg: ⇒ String, e: ⇒ Throwable): Unit

def warn(e: ⇒ Throwable): Any

def warn(msg: ⇒ String): Unit

def countStackFrames(): Int

def destroy(): Unit

final def resume(): Unit

final def stop(arg0: Throwable): Unit

final def stop(): Unit

final def suspend(): Unit