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.
|
FlinkKafkaErrorCode
Error codes used in
FlinkKafkaException . |
FlinkKafkaException
Exception used by
FlinkKafkaProducer and FlinkKafkaConsumer . |
FlinkKafkaProducer
Flink Sink to produce data into a Kafka topic.
|
FlinkKafkaProducer.KafkaTransactionContext
Context associated to this instance of the
FlinkKafkaProducer . |
FlinkKafkaProducer.NextTransactionalIdHint
Keep information required to deduce next safe to use transactional id.
|
FlinkKafkaProducer.Semantic
Semantics that can be chosen.
|
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.NextTransactionalIdHint
Keep information required to deduce next safe to use transactional id.
|
FlinkKafkaProducer011.Semantic
Semantics that can be chosen.
|
FlinkKafkaProducer09
Flink Sink to produce data into a Kafka topic.
|
FlinkKafkaProducerBase
Flink Sink to produce data into a Kafka topic.
|
KafkaDeserializationSchema
The deserialization schema describes how to turn the Kafka ConsumerRecords
into data types (Java/Scala objects) that are processed by Flink.
|
KafkaSerializationSchema |
KafkaTableSinkBase
A version-agnostic Kafka
AppendStreamTableSink . |
KafkaTableSourceBase
A version-agnostic Kafka
StreamTableSource . |
KafkaTableSourceSinkFactoryBase
Factory for creating configured instances of
KafkaTableSourceBase . |
Class and Description |
---|
KafkaDeserializationSchema
The deserialization schema describes how to turn the Kafka ConsumerRecords
into data types (Java/Scala objects) that are processed by Flink.
|
Class and Description |
---|
KafkaDeserializationSchema
The deserialization schema describes how to turn the Kafka ConsumerRecords
into data types (Java/Scala objects) that are processed by Flink.
|
Class and Description |
---|
KafkaDeserializationSchema
The deserialization schema describes how to turn the Kafka ConsumerRecords
into data types (Java/Scala objects) that are processed by Flink.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.