Package | Description |
---|---|
org.apache.flink.streaming.connectors.kafka | |
org.apache.flink.streaming.connectors.kafka.internals |
Class and Description |
---|
KafkaTopicPartition
A serializable representation of a kafka topic and a partition.
|
KafkaTopicPartitionLeader
Serializable Topic Partition info with leader Node information.
|
Class and Description |
---|
Fetcher
A fetcher pulls data from Kafka, from a fix set of partitions.
|
KafkaTopicPartition
A serializable representation of a kafka topic and a partition.
|
KafkaTopicPartitionLeader
Serializable Topic Partition info with leader Node information.
|
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.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.