Flink CDC DataStream API

MySQLCDC
  • Flink MySQL CDC消费数据发送到Kafka,DataStream API
kafka2hudi
  • Flink 消费Kafka CDC数据,并行写到多个Hudi表, 注意这个例子中,库表写死了。使用时可以自己调整