最近做的一个项目,使用的是pg数据库,公司没有成熟的DCD组件,为了实现数据变更消息发布的功能,我使用SpringBoot集成Flink-CDC 采集PostgreSQL变更数据发布到Kafka。 监听数据变化,进行异步通知,做系统内异步任务。 架构方案(懒得写了,看图吧): 2.1、更改配置文件postgresql.conf 2.2、创建数据变更采集用户及赋权 2.3、发布表 3.1、添加Flink-CDC的依赖 3.2 构建数据源 数据转换类,将从数据库采集的转成你想要的格式: 数据实体类 DataChangeInfo package com.jie.flink.cdc.doman; import lombok.Data; import java.io.Serializable; /** * @author zhanggj * @data 2023/1/31 */ @Data public class DataChangeInfo implements Serializable { /** * 变更前数据 */ private String beforeData; /** *...