ProducerSendThread

Instance Constructors

new ProducerSendThread(threadName: String, queue: BlockingQueue[KeyedMessage[K, V]], handler: EventHandler[K, V], queueTime: Long, batchSize: Int, clientId: String)

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
val batchSize: Int
final def checkAccess(): Unit

Definition Classes
Thread
val clientId: String
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
Thread → AnyRef
Annotations
@throws( ... )
def debug(msg: ⇒ String, e: ⇒ Throwable): Unit

Definition Classes
Logging
def debug(e: ⇒ Throwable): Any

Definition Classes
Logging
def debug(msg: ⇒ String): Unit

Definition Classes
Logging
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def error(msg: ⇒ String, e: ⇒ Throwable): Unit

Definition Classes
Logging
def error(e: ⇒ Throwable): Any

Definition Classes
Logging
def error(msg: ⇒ String): Unit

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

Definition Classes
Logging
def fatal(e: ⇒ Throwable): Any

Definition Classes
Logging
def fatal(msg: ⇒ String): Unit

Definition Classes
Logging
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def getContextClassLoader(): ClassLoader

Definition Classes
Thread
def getId(): Long

Definition Classes
Thread
final def getName(): String

Definition Classes
Thread
final def getPriority(): Int

Definition Classes
Thread
def getStackTrace(): Array[StackTraceElement]

Definition Classes
Thread
def getState(): State

Definition Classes
Thread
final def getThreadGroup(): ThreadGroup

Definition Classes
Thread
def getUncaughtExceptionHandler(): UncaughtExceptionHandler

Definition Classes
Thread
val handler: EventHandler[K, V]
def hashCode(): Int

Definition Classes
AnyRef → Any
def info(msg: ⇒ String, e: ⇒ Throwable): Unit

Definition Classes
Logging
def info(e: ⇒ Throwable): Any

Definition Classes
Logging
def info(msg: ⇒ String): Unit

Definition Classes
Logging
def interrupt(): Unit

Definition Classes
Thread
final def isAlive(): Boolean

Definition Classes
Thread
final def isDaemon(): Boolean

Definition Classes
Thread
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
def isInterrupted(): Boolean

Definition Classes
Thread
final def join(): Unit

Definition Classes
Thread
Annotations
@throws( ... )
final def join(arg0: Long, arg1: Int): Unit

Definition Classes
Thread
Annotations
@throws( ... )
final def join(arg0: Long): Unit

Definition Classes
Thread
Annotations
@throws( ... )
var logIdent: String

Attributes
protected
Definition Classes
Logging
lazy val logger: Logger

Definition Classes
Logging
val loggerName: String

Definition Classes
Logging
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def newGauge[T](name: String, metric: Gauge[T]): Gauge[T]

Definition Classes
KafkaMetricsGroup
def newHistogram(name: String, biased: Boolean = true): Histogram

Definition Classes
KafkaMetricsGroup
def newMeter(name: String, eventType: String, timeUnit: TimeUnit): Meter

Definition Classes
KafkaMetricsGroup
def newTimer(name: String, durationUnit: TimeUnit, rateUnit: TimeUnit): Timer

Definition Classes
KafkaMetricsGroup
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
val queue: BlockingQueue[KeyedMessage[K, V]]
val queueTime: Long
def removeMetric(name: String): Unit

Definition Classes
KafkaMetricsGroup
def run(): Unit

Definition Classes
ProducerSendThread → Thread → Runnable
def setContextClassLoader(arg0: ClassLoader): Unit

Definition Classes
Thread
final def setDaemon(arg0: Boolean): Unit

Definition Classes
Thread
final def setName(arg0: String): Unit

Definition Classes
Thread
final def setPriority(arg0: Int): Unit

Definition Classes
Thread
def setUncaughtExceptionHandler(arg0: UncaughtExceptionHandler): Unit

Definition Classes
Thread
def shutdown: Unit
def start(): Unit

Definition Classes
Thread
def swallow(action: ⇒ Unit): Unit

Definition Classes
Logging
def swallowDebug(action: ⇒ Unit): Unit

Definition Classes
Logging
def swallowError(action: ⇒ Unit): Unit

Definition Classes
Logging
def swallowInfo(action: ⇒ Unit): Unit

Definition Classes
Logging
def swallowTrace(action: ⇒ Unit): Unit

Definition Classes
Logging
def swallowWarn(action: ⇒ Unit): Unit

Definition Classes
Logging
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
val threadName: String
def toString(): String

Definition Classes
Thread → AnyRef → Any
def trace(msg: ⇒ String, e: ⇒ Throwable): Unit

Definition Classes
Logging
def trace(e: ⇒ Throwable): Any

Definition Classes
Logging
def trace(msg: ⇒ String): Unit

Definition Classes
Logging
def tryToHandle(events: Seq[KeyedMessage[K, V]]): Unit
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
def warn(msg: ⇒ String, e: ⇒ Throwable): Unit

Definition Classes
Logging
def warn(e: ⇒ Throwable): Any

Definition Classes
Logging
def warn(msg: ⇒ String): Unit

Definition Classes
Logging

Deprecated Value Members

def countStackFrames(): Int

Definition Classes
Thread
Annotations
@Deprecated @deprecated
Deprecated
(Since version ) see corresponding Javadoc for more information.
def destroy(): Unit

Definition Classes
Thread
Annotations
@Deprecated @deprecated
Deprecated
(Since version ) see corresponding Javadoc for more information.
final def resume(): Unit

Definition Classes
Thread
Annotations
@Deprecated @deprecated
Deprecated
(Since version ) see corresponding Javadoc for more information.
final def stop(arg0: Throwable): Unit

Definition Classes
Thread
Annotations
@Deprecated @deprecated
Deprecated
(Since version ) see corresponding Javadoc for more information.
final def stop(): Unit

Definition Classes
Thread
Annotations
@Deprecated @deprecated
Deprecated
(Since version ) see corresponding Javadoc for more information.
final def suspend(): Unit

Definition Classes
Thread
Annotations
@Deprecated @deprecated
Deprecated
(Since version ) see corresponding Javadoc for more information.

class ProducerSendThread[K, V] extends Thread with Logging with KafkaMetricsGroup

Instance Constructors

new ProducerSendThread(threadName: String, queue: BlockingQueue[KeyedMessage[K, V]], handler: EventHandler[K, V], queueTime: Long, batchSize: Int, clientId: String)

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

val batchSize: Int

final def checkAccess(): Unit

val clientId: String

def clone(): AnyRef

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

def debug(e: ⇒ Throwable): Any

def debug(msg: ⇒ String): Unit

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(): 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

val handler: EventHandler[K, V]

def hashCode(): Int

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

def info(e: ⇒ Throwable): Any

def info(msg: ⇒ String): Unit

def interrupt(): Unit

final def isAlive(): Boolean

final def isDaemon(): Boolean

final def isInstanceOf[T0]: Boolean

def isInterrupted(): Boolean

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

final def ne(arg0: AnyRef): Boolean

def newGauge[T](name: String, metric: Gauge[T]): Gauge[T]

def newHistogram(name: String, biased: Boolean = true): Histogram

def newMeter(name: String, eventType: String, timeUnit: TimeUnit): Meter

def newTimer(name: String, durationUnit: TimeUnit, rateUnit: TimeUnit): Timer

final def notify(): Unit

final def notifyAll(): Unit

val queue: BlockingQueue[KeyedMessage[K, V]]

val queueTime: Long

def removeMetric(name: String): 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

val threadName: String

def toString(): String

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

def trace(e: ⇒ Throwable): Any

def trace(msg: ⇒ String): Unit