Interface | Description |
---|---|
KafkaContextAware<T> |
An interface for
KafkaSerializationSchemas that need information
about the context where the Kafka Producer is running along with information about the available
partitions. |
KafkaDeserializationSchema<T> |
The deserialization schema describes how to turn the Kafka ConsumerRecords into data types
(Java/Scala objects) that are processed by Flink.
|
KafkaSerializationSchema<T> |
Class | Description |
---|---|
FlinkKafkaConsumer<T> |
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from Apache
Kafka.
|
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.
|
FlinkKafkaConsumerBase<T> |
Base class of all Flink Kafka Consumer data sources.
|
FlinkKafkaProducer<IN> |
Flink Sink to produce data into a Kafka topic.
|
FlinkKafkaProducer.ContextStateSerializer | |
FlinkKafkaProducer.ContextStateSerializer.ContextStateSerializerSnapshot |
Serializer configuration snapshot for compatibility and format evolution.
|
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.NextTransactionalIdHintSerializer | |
FlinkKafkaProducer.NextTransactionalIdHintSerializer.NextTransactionalIdHintSerializerSnapshot |
Serializer configuration snapshot for compatibility and format evolution.
|
FlinkKafkaProducer.TransactionStateSerializer | |
FlinkKafkaProducer.TransactionStateSerializer.TransactionStateSerializerSnapshot |
Serializer configuration snapshot for compatibility and format evolution.
|
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 | |
FlinkKafkaProducer011.ContextStateSerializer.ContextStateSerializerSnapshot |
Serializer configuration snapshot for compatibility and format evolution.
|
FlinkKafkaProducer011.KafkaTransactionContext |
Context associated to this instance of the
FlinkKafkaProducer011 . |
FlinkKafkaProducer011.KafkaTransactionState |
State for handling transactions.
|
FlinkKafkaProducer011.NextTransactionalIdHint |
Keep information required to deduce next safe to use transactional id.
|
FlinkKafkaProducer011.NextTransactionalIdHintSerializer | |
FlinkKafkaProducer011.NextTransactionalIdHintSerializer.NextTransactionalIdHintSerializerSnapshot |
Serializer configuration snapshot for compatibility and format evolution.
|
FlinkKafkaProducer011.TransactionStateSerializer | |
FlinkKafkaProducer011.TransactionStateSerializer.TransactionStateSerializerSnapshot |
Serializer configuration snapshot for compatibility and format evolution.
|
FlinkKafkaProducerBase<IN> |
Flink Sink to produce data into a Kafka topic.
|
Kafka010TableSink |
Kafka 0.10 table sink for writing data into Kafka.
|
Kafka010TableSource |
Kafka
StreamTableSource for Kafka 0.10. |
Kafka010TableSourceSinkFactory |
Factory for creating configured instances of
Kafka010TableSource . |
Kafka011TableSink |
Kafka 0.11 table sink for writing data into Kafka.
|
Kafka011TableSource |
Kafka
StreamTableSource for Kafka 0.11. |
Kafka011TableSourceSinkFactory |
Factory for creating configured instances of
Kafka011TableSource . |
KafkaTableSink |
Kafka table sink for writing data into Kafka.
|
KafkaTableSinkBase |
A version-agnostic Kafka
AppendStreamTableSink . |
KafkaTableSource |
Kafka
StreamTableSource . |
KafkaTableSourceBase |
A version-agnostic Kafka
StreamTableSource . |
KafkaTableSourceSinkFactory |
Factory for creating configured instances of
KafkaTableSource . |
KafkaTableSourceSinkFactoryBase |
Factory for creating configured instances of
KafkaTableSourceBase . |
Enum | Description |
---|---|
FlinkKafka011ErrorCode |
Error codes used in
FlinkKafka011Exception . |
FlinkKafkaErrorCode |
Error codes used in
FlinkKafkaException . |
FlinkKafkaProducer.Semantic |
Semantics that can be chosen.
|
FlinkKafkaProducer011.Semantic |
Semantics that can be chosen.
|
Exception | Description |
---|---|
FlinkKafka011Exception |
Exception used by
FlinkKafkaProducer011 and FlinkKafkaConsumer011 . |
FlinkKafkaException |
Exception used by
FlinkKafkaProducer and FlinkKafkaConsumer . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.