/DebeziumFlinkHudiSync

Bringing Data from MySQL to Kafka Using Debezium, Joining Kafka Topics with Flink, Upserting into a New Kafka Topic, and Ingesting into Hudi Real-Time

Primary LanguageJupyter NotebookApache License 2.0Apache-2.0

Bringing Data from MySQL to Kafka Using Debezium, Joining Kafka Topics with Flink, Upserting into a New Kafka Topic, and Ingesting into Hudi Real-Time

Untitled Diagram

Code to be added soon