FlinkCDC消费MySQL Binlog 并推送到Kafka(一)

FlinkCDC消费MySQL Binlog 并推送到Kafka(一)

FlinkCDC消费MySQL Binlog 并推送到Kafka(一)

环境:Flink Version: 1.19.0

容器:Docker,Flink:latest

依赖Refer:Docker快速拉起Flink集群 、MySQL服务并打开GTID

一、下载以下三个CDC依赖到Flink lib目录

二、复制依赖到各个Flink容器 /opt/flink/lib目录

三、重启Flink集群生效

四、准备好kafka集群和 创建topic

依赖Refer: https://cpp.la/582.html#kafka-dockerKafka

五、打开FlinkSQL客户端

六、开启MySQL Source

七、开启Kafka Sink

八、执行插入

九、观察kafka消息

By: cpp.la ,2024-04-09 , Mark ,FlinkCDC消费MySQL Binlog 并推送到Kafka(一)

One Reply to “FlinkCDC消费MySQL Binlog 并推送到Kafka(一)”

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注