postgres15 flink cdc同步测试

配置flink环境

解压flink，设置FLINK_HOME环境变量，复制 postgrep-connector 依赖包到flink的lib目录

重启 flink

配置postgres参数

确认数据库的同步配置

在数据库侧新建同步账号及表

在flink中建同步表

查看flink表数据

增量测试

在数据库表中添加一组增量数据

新增数据自动同步到flink表中