Package org.apache.paimon.flink.kafka

Class Summary

Class	Description
KafkaLogDeserializationSchema	A KafkaDeserializationSchema for the table with primary key in log store.
KafkaLogOptions	Options for kafka log.
KafkaLogSerializationSchema	A KafkaRecordSerializationSchema for the table in log store.
KafkaLogSinkProvider	A Kafka LogSinkProvider.
KafkaLogSourceProvider	A Kafka LogSourceProvider.
KafkaLogStoreFactory	The Kafka LogStoreTableFactory implementation.
KafkaLogStoreRegister	KafkaLogStoreRegister is used to register/unregister topics in Kafka for paimon table.
KafkaSinkFunction	A FlinkKafkaProducer which implements LogSinkFunction to register WriteCallback.