consumer

Type Members

1. class AssignmentContext extends AnyRef

2. case class Blacklist(rawRegex: String) extends TopicFilter with Product with Serializable

3. class ConsumerConfig extends ZKConfig

4. trait ConsumerConnector extends AnyRef

   Main interface for consumer

5. class ConsumerFetcherManager extends AbstractFetcherManager

   Usage: Once ConsumerFetcherManager is created, startConnections() and stopAllConnections() can be called repeatedly until shutdown() is called.

6. class ConsumerFetcherThread extends AbstractFetcherThread

7. class ConsumerIterator[K, V] extends IteratorTemplate[MessageAndMetadata[K, V]] with Logging

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

8. case class ConsumerThreadId(consumer: String, threadId: Int) extends Ordered[ConsumerThreadId] with Product with Serializable

9. class ConsumerTimeoutException extends RuntimeException

10. class ConsumerTopicMetrics extends KafkaMetricsGroup

    Annotations

    @threadsafe()

11. class ConsumerTopicStats extends Logging

    Tracks metrics for each topic the given consumer client has consumed data from.

12. class FetchRequestAndResponseMetrics extends KafkaMetricsGroup

13. class FetchRequestAndResponseStats extends AnyRef

    Tracks metrics of the requests made by a given consumer client to all brokers, and the responses obtained from the brokers.

14. case class FetchedDataChunk(messages: ByteBufferMessageSet, topicInfo: PartitionTopicInfo, fetchOffset: Long) extends Product with Serializable

15. class KafkaStream[K, V] extends Iterable[MessageAndMetadata[K, V]] with Iterable[MessageAndMetadata[K, V]]

16. trait PartitionAssignor extends AnyRef

17. class PartitionTopicInfo extends Logging

18. class RangeAssignor extends PartitionAssignor with Logging

    Range partitioning works on a per-topic basis.

19. class RoundRobinAssignor extends PartitionAssignor with Logging

    The round-robin partition assignor lays out all the available partitions and all the available consumer threads.

20. class SimpleConsumer extends Logging

    A consumer of kafka messages

21. trait TopicEventHandler[T] extends AnyRef

22. sealed abstract class TopicFilter extends Logging

23. case class Whitelist(rawRegex: String) extends TopicFilter with Product with Serializable

24. class ZookeeperTopicEventWatcher extends Logging