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
Deprecated.
Please use
KafkaSink . |
FlinkKafkaProducer.KafkaTransactionContext
Deprecated.
Context associated to this instance of the
FlinkKafkaProducer . |
FlinkKafkaProducer.KafkaTransactionState
Deprecated.
State for handling transactions.
|
FlinkKafkaProducer.NextTransactionalIdHint
Deprecated.
Keep information required to deduce next safe to use transactional id.
|
FlinkKafkaProducer.Semantic
Deprecated.
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 |
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
Deprecated.
|
FlinkKafkaConsumerBase
Base class of all Flink Kafka Consumer data sources.
|
FlinkKafkaException
Exception used by
FlinkKafkaProducer and FlinkKafkaConsumer . |
FlinkKafkaProducer
Deprecated.
Please use
KafkaSink . |
FlinkKafkaProducer.KafkaTransactionState
Deprecated.
State for handling transactions.
|
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.