Uses of Package
org.apache.flink.streaming.connectors.kafka

Packages that use org.apache.flink.streaming.connectors.kafka

Package	Description
org.apache.flink.streaming.connectors.kafka

Classes in org.apache.flink.streaming.connectors.kafka used by org.apache.flink.streaming.connectors.kafka

Class and Description
FlinkKafka011ErrorCode Error codes used in FlinkKafka011Exception.
FlinkKafka011Exception Exception used by FlinkKafkaProducer011 and FlinkKafkaConsumer011.
FlinkKafkaConsumer010 The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from Apache Kafka 0.10.x.
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 Deprecated. This class is deprecated since the factory methods writeToKafkaWithTimestamps for the producer are also deprecated.
FlinkKafkaProducer011 Flink Sink to produce data into a Kafka topic.
FlinkKafkaProducer011.KafkaTransactionContext Context associated to this instance of the FlinkKafkaProducer011.
FlinkKafkaProducer011.Semantic Semantics that can be chosen.
FlinkKafkaProducer08 Flink Sink to produce data into a Kafka topic.
FlinkKafkaProducer09 Flink Sink to produce data into a Kafka topic.
FlinkKafkaProducerBase Flink Sink to produce data into a Kafka topic.
Kafka010AvroTableSource Kafka StreamTableSource for Kafka 0.10.
Kafka010AvroTableSource.Builder A builder to configure and create a Kafka010AvroTableSource.
Kafka010JsonTableSink Kafka 0.10 KafkaTableSink that serializes data in JSON format.
Kafka010JsonTableSource Kafka StreamTableSource for Kafka 0.10.
Kafka010JsonTableSource.Builder A builder to configure and create a Kafka010JsonTableSource.
Kafka011AvroTableSource Kafka StreamTableSource for Kafka 0.11.
Kafka011AvroTableSource.Builder A builder to configure and create a Kafka011AvroTableSource.
Kafka011JsonTableSource Kafka StreamTableSource for Kafka 0.11.
Kafka011JsonTableSource.Builder A builder to configure and create a Kafka011JsonTableSource.
Kafka08AvroTableSource Kafka StreamTableSource for Kafka 0.8.
Kafka08AvroTableSource.Builder A builder to configure and create a Kafka08AvroTableSource.
Kafka08JsonTableSink Kafka 0.8 KafkaTableSink that serializes data in JSON format.
Kafka08JsonTableSource Kafka StreamTableSource for Kafka 0.8.
Kafka08JsonTableSource.Builder A builder to configure and create a Kafka08JsonTableSource.
Kafka09AvroTableSource Kafka StreamTableSource for Kafka 0.9.
Kafka09AvroTableSource.Builder A builder to configure and create a Kafka09AvroTableSource.
Kafka09JsonTableSink Kafka 0.9 KafkaTableSink that serializes data in JSON format.
Kafka09JsonTableSource Kafka StreamTableSource for Kafka 0.9.
Kafka09JsonTableSource.Builder A builder to configure and create a Kafka09JsonTableSource.
KafkaAvroTableSource A version-agnostic Kafka Avro StreamTableSource.
KafkaAvroTableSource.Builder Abstract builder for a KafkaAvroTableSource to be extended by builders of subclasses of KafkaAvroTableSource.
KafkaJsonTableSink Base class for KafkaTableSink that serializes data in JSON format.
KafkaJsonTableSource A version-agnostic Kafka JSON StreamTableSource.
KafkaJsonTableSource.Builder Abstract builder for a KafkaJsonTableSource to be extended by builders of subclasses of KafkaJsonTableSource.
KafkaTableSink A version-agnostic Kafka AppendStreamTableSink.
KafkaTableSource A version-agnostic Kafka StreamTableSource.
KafkaTableSource.Builder Abstract builder for a KafkaTableSource to be extended by builders of subclasses of KafkaTableSource.