Class | Description |
---|---|
FlinkKafkaConsumer08<T> |
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.8.x.
|
FlinkKafkaConsumer081<T> | Deprecated |
FlinkKafkaConsumer082<T> | Deprecated |
FlinkKafkaConsumer09<T> |
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.9.x.
|
FlinkKafkaConsumerBase<T> |
Base class of all Flink Kafka Consumer data sources.
|
FlinkKafkaProducer<IN> | Deprecated |
FlinkKafkaProducer08<IN> |
Flink Sink to produce data into a Kafka topic.
|
FlinkKafkaProducer09<IN> |
Flink Sink to produce data into a Kafka topic.
|
FlinkKafkaProducerBase<IN> |
Flink Sink to produce data into a Kafka topic.
|
Kafka08JsonTableSource |
Kafka
StreamTableSource for Kafka 0.8. |
Kafka08TableSource |
Kafka
StreamTableSource for Kafka 0.8. |
Kafka09JsonTableSource |
Kafka
StreamTableSource for Kafka 0.9. |
Kafka09TableSource |
Kafka
StreamTableSource for Kafka 0.9. |
KafkaJsonTableSource |
A version-agnostic Kafka JSON
StreamTableSource . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.