Package

kafka.javaapi

consumer

Permalink

package consumer

Visibility
  1. Public
  2. All

Type Members

  1. trait ConsumerConnector extends AnyRef

    Permalink

  2. trait ConsumerRebalanceListener extends AnyRef

    Permalink

  3. class SimpleConsumer extends AnyRef

    Permalink

    A consumer of kafka messages

    A consumer of kafka messages

    Annotations
    @threadsafe()

Ungrouped