Interface | Description |
---|---|
Fetcher |
A fetcher pulls data from Kafka, from a fix set of partitions.
|
OffsetHandler |
The offset handler is responsible for locating the initial partition offsets
where the source should start reading, as well as committing offsets from completed
checkpoints.
|
Class | Description |
---|---|
ClosableBlockingQueue<E> |
A special form of blocking queue with two additions:
The queue can be closed atomically when empty.
|
KafkaTopicPartition |
A serializable representation of a kafka topic and a partition.
|
KafkaTopicPartitionLeader |
Serializable Topic Partition info with leader Node information.
|
LegacyFetcher |
This fetcher uses Kafka's low-level API to pull data from a specific
set of topics and partitions.
|
PartitionerWrapper |
Hacky wrapper to send an object instance through a Properties - map.
|
ZookeeperOffsetHandler |
Handler for committing Kafka offsets to Zookeeper and to retrieve them again.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.