问题一:Flink CDC postgresql-cdc这两个配置有什么关系吗?
Flink CDC postgresql-cdc中heartbeat.interval.ms配置与deberzium中这两个配置有什么关系吗?
参考答案:
我理解没啥区别,flink-connector-pgsql-cdc是基于debezium开发出来的
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584495
问题二:Flink CDC想同步的数据,加上特别的字段, 可以加吗?
Flink CDC想同步的数据,加上特别的字段, 可以加吗?
参考答案:
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584494
问题三:Flink CDC有办法直接匹配库吗?
Flink CDC有办法直接匹配库吗?
参考答案:
好像是不支持的,一般变库名的不常见,可以加profiex,ods_
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584491
问题四:Flink CDC同步数据库,库名称变了,route只能到表级别,哪里能改吗?
Flink CDC同步数据库,库名称变了,route只能到表级别,哪里能改吗?
参考答案:
这个可以自己做下二开支持的哈 这一块的逻辑不复杂,
我这边是搞了个mapper 优先route 规则 然后 指定库 映射 和表名统一前缀后缀
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584488
问题五:Flink CDC指点一下呗?
Flink CDC指点一下呗?
参考答案:
如果是 Datastream 作业,则需要根据不同的 Flink 版本引入不同版本的 flink-shaded-guava 依赖,DataStream 用户可以参考 SQL Connector 的打包方式管理正确的依赖。
关于本问题的更多回答可点击进行查看: