本文首发于我的个人博客网站等待下一个秋-Flink什么是CDC?CDC是(ChangeDataCapture变更数据获取)的简称。核心思想是,监测并捕获数据库的变动(包括数据或数据表的插入INSERT、更新UPDATE、删除DELETE等),将这些变更按发生的顺序完整记录下来,写入到消息中间件中以供其他服务进行订阅及消费。[图片上传失败...(image-cacb2d-1663151981555)]1.环境准备mysqlkafka2.3flink1.13.5onyarn说明:如果没有安装hadoop,那么可以不用yarn,直接用flinkstandalone环境吧。2.下载下列依赖包下面两个地