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

Class Summary

Class	Description
FlinkKafkaConsumer010<T>	The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from Apache Kafka 0.10.x.
FlinkKafkaConsumer011<T>	The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from Apache Kafka 0.11.x.
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 Use FlinkKafkaConsumer08
FlinkKafkaConsumer082<T>	Deprecated Use FlinkKafkaConsumer08
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 Use FlinkKafkaProducer08.
FlinkKafkaProducer010<T>	Flink Sink to produce data into a Kafka topic.
FlinkKafkaProducer010.FlinkKafkaProducer010Configuration<T>	Deprecated This class is deprecated since the factory methods writeToKafkaWithTimestamps for the producer are also deprecated.
FlinkKafkaProducer011<IN>	Flink Sink to produce data into a Kafka topic.
FlinkKafkaProducer011.ContextStateSerializer	TypeSerializer for FlinkKafkaProducer011.KafkaTransactionContext.
FlinkKafkaProducer011.KafkaTransactionContext	Context associated to this instance of the FlinkKafkaProducer011.
FlinkKafkaProducer011.NextTransactionalIdHint	Keep information required to deduce next safe to use transactional id.
FlinkKafkaProducer011.TransactionStateSerializer	TypeSerializer for KafkaTransactionState.
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.
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.
Kafka010TableSource	Kafka StreamTableSource for Kafka 0.10.
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.
Kafka011TableSource	Kafka StreamTableSource for Kafka 0.11.
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.
Kafka08TableSource	Kafka StreamTableSource for Kafka 0.8.
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.
Kafka09TableSource	Kafka StreamTableSource for Kafka 0.9.
KafkaAvroTableSource	A version-agnostic Kafka Avro StreamTableSource.
KafkaAvroTableSource.Builder<T extends KafkaAvroTableSource,B extends 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<T extends KafkaJsonTableSource,B extends 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<T extends KafkaTableSource,B extends KafkaTableSource.Builder>	Abstract builder for a KafkaTableSource to be extended by builders of subclasses of KafkaTableSource.

Enum Summary

Enum	Description
FlinkKafka011ErrorCode	Error codes used in FlinkKafka011Exception.
FlinkKafkaProducer011.Semantic	Semantics that can be chosen.

Exception Summary

Exception	Description
FlinkKafka011Exception	Exception used by FlinkKafkaProducer011 and FlinkKafkaConsumer011.