FlinkKafkaConsumer<T> |
Deprecated |
FlinkKafkaConsumerBase<T> |
Base class of all Flink Kafka Consumer data sources.
|
FlinkKafkaProducer<IN> |
Deprecated
|
FlinkKafkaProducer.ContextStateSerializer |
|
FlinkKafkaProducer.ContextStateSerializer.ContextStateSerializerSnapshot |
Serializer configuration snapshot for compatibility and format evolution.
|
FlinkKafkaProducer.KafkaTransactionContext |
|
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.
|
FlinkKafkaProducer011 |
Compatibility class to make migration possible from the 0.11 connector to the universal one.
|
FlinkKafkaProducer011.ContextStateSerializer |
|
FlinkKafkaProducer011.ContextStateSerializer.ContextStateSerializerSnapshot |
|
FlinkKafkaProducer011.NextTransactionalIdHint |
|
FlinkKafkaProducer011.NextTransactionalIdHintSerializer |
|
FlinkKafkaProducer011.NextTransactionalIdHintSerializer.NextTransactionalIdHintSerializerSnapshot |
|
FlinkKafkaProducer011.TransactionStateSerializer |
|
FlinkKafkaProducer011.TransactionStateSerializer.TransactionStateSerializerSnapshot |
|
FlinkKafkaProducerBase<IN> |
Flink Sink to produce data into a Kafka topic.
|