Instance Constructors
-
new
ConsumerThread
(stream: KafkaStream[Array[Byte], Array[Byte]], mirrorDataChannel: DataChannel, threadId: Int)
Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
def
asInstanceOf
[T0]
: T0
-
def
awaitShutdown
(): Unit
-
def
checkAccess
(): Unit
-
def
clone
(): AnyRef
-
def
debug
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
debug
(e: ⇒ Throwable): Any
-
def
debug
(msg: ⇒ String): Unit
-
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
-
def
getClass
(): java.lang.Class[_]
-
def
getContextClassLoader
(): ClassLoader
-
def
getId
(): Long
-
def
getName
(): String
-
def
getPriority
(): Int
-
def
getStackTrace
(): Array[StackTraceElement]
-
def
getState
(): State
-
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
interrupt
(): Unit
-
def
isAlive
(): Boolean
-
def
isDaemon
(): Boolean
-
def
isInstanceOf
[T0]
: Boolean
-
def
isInterrupted
(): Boolean
-
def
join
(): Unit
-
def
join
(arg0: Long, arg1: Int): Unit
-
def
join
(arg0: Long): Unit
-
var
logIdent
: String
-
lazy val
logger
: Logger
-
val
loggerName
: String
-
def
ne
(arg0: AnyRef): Boolean
-
def
newGauge
[T]
(name: String, metric: Gauge[T], tags: Map[String, String]): Gauge[T]
-
def
newHistogram
(name: String, biased: Boolean = true, tags: Map[String, String] = Map.empty): Histogram
-
def
newMeter
(name: String, eventType: String, timeUnit: TimeUnit, tags: Map[String, String] = Map.empty): Meter
-
def
newTimer
(name: String, durationUnit: TimeUnit, rateUnit: TimeUnit, tags: Map[String, String] = Map.empty): Timer
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
def
removeMetric
(name: String, tags: Map[String, String] = Map.empty): Unit
-
def
run
(): Unit
-
def
setContextClassLoader
(arg0: ClassLoader): Unit
-
def
setDaemon
(arg0: Boolean): Unit
-
def
setName
(arg0: String): Unit
-
def
setPriority
(arg0: Int): Unit
-
def
setUncaughtExceptionHandler
(arg0: UncaughtExceptionHandler): 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
-
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
-
def
wait
(): Unit
-
def
wait
(arg0: Long, arg1: Int): Unit
-
def
wait
(arg0: Long): Unit
-
def
warn
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
warn
(e: ⇒ Throwable): Any
-
def
warn
(msg: ⇒ String): Unit
Deprecated Value Members
-
def
countStackFrames
(): Int
-
def
destroy
(): Unit
-
def
resume
(): Unit
-
def
stop
(arg0: Throwable): Unit
-
def
stop
(): Unit
-
def
suspend
(): Unit
Inherited from Thread
Inherited from Runnable
Inherited from AnyRef
Inherited from Any