Package | Description |
---|---|
org.apache.flink.streaming.connectors.kafka |
Class and Description |
---|
FlinkKafkaConsumer08
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.8.x.
|
FlinkKafkaConsumer09
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.9.x.
|
FlinkKafkaConsumerBase
Base class of all Flink Kafka Consumer data sources.
|
FlinkKafkaProducer010.FlinkKafkaProducer010Configuration
Configuration object returned by the writeToKafkaWithTimestamps() call.
|
FlinkKafkaProducer08
Flink Sink to produce data into a Kafka topic.
|
FlinkKafkaProducerBase
Flink Sink to produce data into a Kafka topic.
|
Kafka08JsonTableSink
Kafka 0.8
KafkaTableSink that serializes data in JSON format. |
Kafka09JsonTableSink
Kafka 0.9
KafkaTableSink that serializes data in JSON format. |
Kafka09JsonTableSource
Kafka
StreamTableSource for Kafka 0.9. |
Kafka09TableSource
Kafka
StreamTableSource for Kafka 0.9. |
KafkaJsonTableSink
Base class for
KafkaTableSink that serializes data in JSON format |
KafkaJsonTableSource
A version-agnostic Kafka JSON
StreamTableSource . |
KafkaTableSink
A version-agnostic Kafka
StreamTableSink . |
KafkaTableSource
A version-agnostic Kafka
StreamTableSource . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.