Package org.apache.paimon.flink.action.cdc.kafka

Class Summary

Class	Description
KafkaActionUtils	Utils for Kafka Action.
KafkaDebeziumAvroDeserializationSchema	A simple deserialization schema for CdcSourceRecord.
KafkaDebeziumJsonDeserializationSchema	A simple deserialization schema for CdcSourceRecord.
KafkaSyncDatabaseAction	Synchronize database from Kafka.
KafkaSyncDatabaseActionFactory	Factory to create KafkaSyncDatabaseAction.
KafkaSyncTableAction	Synchronize table from Kafka.
KafkaSyncTableActionFactory	Factory to create KafkaSyncTableAction.