该版本升级支持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段

最后修改于
上一篇