Flink cdc 2.2.0版本不能配置指定时间戳或者binlog位置采集

介绍

源码可以看到!!

这个是Flink cdc 2.2.0版本的,这里只有两种Mode,想要指定时间戳或者是binlog文件位置,则需要升级cdc版本,我选择了2.3.0解决了问题!

注意

Flink cdc的包和Flink的包非常容易出现包的版本冲突,可以根据报错信息进行相关包的排除,如果需要用cdc,则最好优先使用Flink cdc里面的包

请使用浏览器的分享功能分享到微信等