FetchRequest

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def canEqual(arg0: Any): Boolean

val clientId: String

def clone(): AnyRef

val correlationId: Int

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

def debug(e: ⇒ Throwable): Any

def debug(msg: ⇒ String): Unit

def describe(details: Boolean): String

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

def finalize(): Unit

final def getClass(): java.lang.Class[_]

def handleError(e: Throwable, requestChannel: RequestChannel, request: Request): Unit

def hashCode(): Int

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

def info(e: ⇒ Throwable): Any

def info(msg: ⇒ String): Unit

def isFromFollower: Boolean

def isFromLowLevelConsumer: Boolean

def isFromOrdinaryConsumer: Boolean

final def isInstanceOf[T0]: Boolean

var logIdent: String

lazy val logger: Logger

val loggerName: String

val maxWait: Int

val minBytes: Int

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def numPartitions: Int

def productArity: Int

def productElement(arg0: Int): Any

def productIterator: Iterator[Any]

def productPrefix: String

val replicaId: Int

val requestId: Option[Short]

val requestInfo: Map[TopicAndPartition, PartitionFetchInfo]

lazy val requestInfoGroupedByTopic: Map[String, Map[TopicAndPartition, PartitionFetchInfo]]

Partitions the request info into a map of maps (one for each topic).

def sizeInBytes: Int

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

val versionId: Short

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 writeTo(buffer: ByteBuffer): Unit

def productElements: Iterator[Any]