consumer

class ConsumerConfig extends ZKConfig

trait ConsumerConnector extends AnyRef

Main interface for consumer

class ConsumerIterator extends IteratorTemplate[Message]

An iterator that blocks until a value can be read from the supplied queue.

class ConsumerTimeoutException extends RuntimeException

class FetcherRunnable extends Thread

class KafkaMessageStream extends Iterable[Message] with Iterable[Message]

All calls to elements should produce the same thread-safe iterator? Should have a separate thread that feeds messages into a blocking queue for processing.

class SimpleConsumer extends AnyRef

A consumer of kafka messages

class SimpleConsumerStats extends SimpleConsumerStatsMBean

trait SimpleConsumerStatsMBean extends AnyRef

trait ZookeeperConsumerConnectorMBean extends AnyRef

JMX interface for monitoring consumer

object ConsoleConsumer extends AnyRef

Consumer that dumps messages out to standard out.

object Consumer extends AnyRef

object ConsumerConfig extends AnyRef

object SimpleConsumerStats extends AnyRef

package storage