flink cdc怎么指定位点，从某个位点开始消费mysql的Binlog？

2022-08-04 15:42:00 【阿里云问答】

采纳答案1：

新版本的是不支持的，2.0之前的版本可以支持指定binlog消费.startupOptions(StartupOptions.specificOffset("",0))//文件名和消费位点（此答案整理自Flink CDC 社区）

版权声明
本文为[阿里云问答]所创，转载请带上原文链接，感谢
https://developer.aliyun.com/ask/446907

当前位置：网站首页>flink cdc怎么指定位点，从某个位点开始消费mysql的Binlog？