Class

kafka.consumer

SimpleConsumer

Related Doc: package consumer

Permalink

class SimpleConsumer extends Logging

A consumer of kafka messages

Annotations
@threadsafe()
Linear Supertypes
Logging, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. SimpleConsumer
  2. Logging
  3. AnyRef
  4. Any
  1. Hide All
  2. Show all
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SimpleConsumer(host: String, port: Int, soTimeout: Int, bufferSize: Int, clientId: String)

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

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

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

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

    Permalink
    Definition Classes
    Any
  5. val bufferSize: Int

    Permalink
  6. val clientId: String

    Permalink
  7. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  8. def close(): Unit

    Permalink
  9. def commitOffsets(request: OffsetCommitRequest): OffsetCommitResponse

    Permalink

    Commit offsets for a topic Version 0 of the request will commit offsets to Zookeeper and version 1 and above will commit offsets to Kafka.

    Commit offsets for a topic Version 0 of the request will commit offsets to Zookeeper and version 1 and above will commit offsets to Kafka.

    request

    a kafka.api.OffsetCommitRequest object.

    returns

    a kafka.api.OffsetCommitResponse object.

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

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

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

    Permalink
    Definition Classes
    Logging
  13. def disconnectToHandleJavaIOBug(): Unit

    Permalink

    Unblock thread by closing channel and triggering AsynchronousCloseException if a read operation is in progress.

    Unblock thread by closing channel and triggering AsynchronousCloseException if a read operation is in progress.

    This handles a bug found in Java 1.7 and below, where interrupting a thread can not correctly unblock the thread from waiting on ReadableByteChannel.read().

  14. def earliestOrLatestOffset(topicAndPartition: TopicAndPartition, earliestOrLatest: Long, consumerId: Int): Long

    Permalink

    Get the earliest or latest offset of a given topic, partition.

    Get the earliest or latest offset of a given topic, partition.

    topicAndPartition

    Topic and partition of which the offset is needed.

    earliestOrLatest

    A value to indicate earliest or latest offset.

    consumerId

    Id of the consumer which could be a consumer client, SimpleConsumerShell or a follower broker.

    returns

    Requested offset.

  15. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  16. def equals(arg0: Any): Boolean

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

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

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

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

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

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

    Permalink
    Definition Classes
    Logging
  23. def fetch(request: FetchRequest): FetchResponse

    Permalink

    Fetch a set of messages from a topic.

    Fetch a set of messages from a topic.

    request

    specifies the topic name, topic partition, starting byte offset, maximum bytes to be fetched.

    returns

    a set of fetched messages

  24. def fetchOffsets(request: OffsetFetchRequest): OffsetFetchResponse

    Permalink

    Fetch offsets for a topic Version 0 of the request will fetch offsets from Zookeeper and version 1 and above will fetch offsets from Kafka.

    Fetch offsets for a topic Version 0 of the request will fetch offsets from Zookeeper and version 1 and above will fetch offsets from Kafka.

    request

    a kafka.api.OffsetFetchRequest object.

    returns

    a kafka.api.OffsetFetchResponse object.

  25. def finalize(): Unit

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

    Permalink
    Definition Classes
    AnyRef → Any
  27. def getOffsetsBefore(request: OffsetRequest): OffsetResponse

    Permalink

    Get a list of valid offsets (up to maxSize) before the given time.

    Get a list of valid offsets (up to maxSize) before the given time.

    request

    a kafka.api.OffsetRequest object.

    returns

    a kafka.api.OffsetResponse object.

  28. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  29. val host: String

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

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

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

    Permalink
    Definition Classes
    Logging
  33. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  34. var logIdent: String

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  35. lazy val logger: Logger

    Permalink
    Definition Classes
    Logging
  36. val loggerName: String

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

    Permalink
    Definition Classes
    AnyRef
  38. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  39. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  40. val port: Int

    Permalink
  41. def send(request: GroupCoordinatorRequest): GroupCoordinatorResponse

    Permalink
  42. def send(request: TopicMetadataRequest): TopicMetadataResponse

    Permalink
  43. val soTimeout: Int

    Permalink
  44. def swallow(action: ⇒ Unit): Unit

    Permalink
    Definition Classes
    Logging
  45. def swallowDebug(action: ⇒ Unit): Unit

    Permalink
    Definition Classes
    Logging
  46. def swallowError(action: ⇒ Unit): Unit

    Permalink
    Definition Classes
    Logging
  47. def swallowInfo(action: ⇒ Unit): Unit

    Permalink
    Definition Classes
    Logging
  48. def swallowTrace(action: ⇒ Unit): Unit

    Permalink
    Definition Classes
    Logging
  49. def swallowWarn(action: ⇒ Unit): Unit

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

    Permalink
    Definition Classes
    AnyRef
  51. def toString(): String

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

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

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

    Permalink
    Definition Classes
    Logging
  55. final def wait(): Unit

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

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

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

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

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

    Permalink
    Definition Classes
    Logging

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped