该版本升级支持Flink1.12.1版本。并升级了几个重要特性
1、支持从特定的MySQL Binlog位置读取
2、支持“initial”,“earliest-offset”,“latest-offset”启动模式选项
3、支持从特定时间戳读取binlog
4、删除日志记录安全属性
5、支持Debezium版本为1.4.1.Final
6、支持postgres-cdc连接器的'slot.name'选项
7、checkpoint完成后,将LSN偏移量冲刷到PG,以避免无限个WAL段
最后修改于