FlinkCDC读取MySQL并写入Kafka案例

场景应用：将MySQL的变化数据转为实时流输出到Kafka中。

1. MySQL的配置

2. FlinkCDC的开发

2.1 Pom文件配置

2.2 读取MySQL

2.3 自定义输出的数据的格式

2.4 写入到Kafka

标签：输出,读取,写入,Kafka,FlinkCDC,MySQL
来源： https://www.cnblogs.com/30go/p/15773357.html