问题一:flinkcdc现在最新的稳定版本是啥?
flinkcdc现在最新的稳定版本是啥?
参考回答:
最新的 Flink CDC 版本是 2.4.0。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/567543
问题二:Flink CDC通过mysql-cdc就可以动态监听数据的变动?
Flink CDC通过mysql-cdc就可以动态监听数据的变动?
参考回答:
是的,但是需要你向flink集群传递jar包
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/567542
问题三:Flink CDC监听的表是datastream,然后通过table api拿到维表,是这样吗?
Flink CDC监听的表是datastream,然后通过table api拿到维表,把table api再转成datastream,最后join,是这样吗?
参考回答:
我这边是sql操作的比较多,没有这么多转换操作,直接都用table-api就行
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/567541
问题四:Flink CDC中debezium支持oracle的dg库吗?
Flink CDC中debezium支持oracle的dg库吗?
参考回答:
Debezium本身并不直接支持 Oracle Data Guard (DG) 库。这是因为 Debezium 是基于 JDBC 的工具,只能读取本地实例上的数据库变化。然而,有一些第三方工具,比如 GoldenGate、LogMiner 等,可以从 DG 库中捕获变更并将它们推送到 Kafka 或其他目标。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566226
问题五:Flink CDC需要如何解决增量慢的问题啊?
Flink CDC在线读取oracle19c 无法使用log.mining.continuous.mine 字段,需要如何解决增量慢的问题啊?
参考回答:
全表读取阶段效率慢、存在反压,应该如何解决?
可能是下游节点处理太慢导致反压了。因此您需要先排查下游节点是否存在反压。如果存在,则需要先解决下游节点的反压问题。您可以通过以下方式处理:
增加并发数。
开启minibatch等聚合优化参数(下游聚合节点)。https://help.aliyun.com/zh/flink/support/faq-about-cdc?spm=a2c4g.11186623.0.i24
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/567539