问题一:Flink CDC 的parallelism数量必须要小于slot数量对吧?
Flink CDC 的parallelism数量必须要小于slot数量对吧?
参考答案:
是的,取决于source的并发数,一个slot只能一个连接。如果下游幂等,可以skip backfill。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/609884
问题二:Flink CDC里我用springboot + flink,这个方案 也应该是可以的吧?
Flink CDC里我用springboot + flink,因为有部分规则是需要调用 微服务的 feign接口来获取结果,多个Listener监听多个库,采用 canal - mq - 微服务消费 - 写结果 现在想把 canal - mq 这一层干掉,怎么处理?
参考答案:
不要加任何spring 的东西,flink不需要spring,开发平台需要。把数据塞到消息队列里面,flink接消息队列。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/609876
问题三:Flink CDC里从pg库采集cdc数据,flink程序断了之后,为啥不能指定从断的地方重新消费?
Flink CDC里从pg库采集cdc数据,flink程序。断了之后,为啥不能指定从断的地方重新消费changelog数据呢,现在代码里只支持initial和latest,其它模式不支持怎么办?
参考答案:
这个是pg本身的限制,目前不支持从点位和时间戳启动。增量快照应该是支持断点续传的。目前仅支持initial和latest-offset。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/609875
问题四:flinkcdc 3.0支持flink 1.19吗?
flinkcdc 3.0支持flink 1.19吗?
参考答案:
按理说支持,你得看guavua,就那个特殊点,还有kafka依赖。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/609861
问题五:Flink cdc3.1出来了吗?
Flink cdc3.1出来了吗? 看官网上写的。
参考答案:
这是 master 文档,还没有发布呢,你要看 release 的。
关于本问题的更多回答可点击进行查看: