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 |
---|
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.KafkaTransactionState
State for handling transactions.
|
FlinkKafkaProducer.NextTransactionalIdHint
Keep information required to deduce next safe to use transactional id.
|
FlinkKafkaProducer.Semantic
Semantics that can be chosen.
|
KafkaDeserializationSchema
The deserialization schema describes how to turn the Kafka ConsumerRecords into data types
(Java/Scala objects) that are processed by Flink.
|
KafkaSerializationSchema |
KafkaTableSinkBase
Deprecated.
Use
KafkaDynamicSink via KafkaDynamicTableFactory . |
KafkaTableSourceBase
Deprecated.
|
KafkaTableSourceSinkFactoryBase
Deprecated.
|
Class and Description |
---|
KafkaContextAware
An interface for
KafkaSerializationSchemas that need information
about the context where the Kafka Producer is running along with information about the available
partitions. |
KafkaDeserializationSchema
The deserialization schema describes how to turn the Kafka ConsumerRecords into data types
(Java/Scala objects) that are processed by Flink.
|
KafkaSerializationSchema |
Class and Description |
---|
FlinkKafkaConsumer
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from Apache
Kafka.
|
FlinkKafkaConsumerBase
Base class of all Flink Kafka Consumer data sources.
|
FlinkKafkaException
Exception used by
FlinkKafkaProducer and FlinkKafkaConsumer . |
FlinkKafkaProducer
Flink Sink to produce data into a Kafka topic.
|
FlinkKafkaProducer.KafkaTransactionState
State for handling transactions.
|
Class and Description |
---|
FlinkKafkaConsumer
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from Apache
Kafka.
|
FlinkKafkaProducer
Flink Sink to produce data into a Kafka topic.
|
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–2022 The Apache Software Foundation. All rights reserved.