问题一:Flink CDC 里有多个系统,各个系统都有多张表要做实时同步,一般生产上大家怎么来做这个同步啊?
Flink CDC 里有多个系统,各个系统都有多张表要做实时同步,一般生产上大家怎么来做这个同步,有朋友能分享一下么?如果用sql提交任务,太繁琐了,不好维护。
参考答案:
整库同步。cdc好像没有实现,dinky里面有实现,paimon也有实现,不过我没用过
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/602845
问题二:Flink CDC 里3.0的cdc还是支持原来的通过手动写代码用ds方式来监听吧?
Flink CDC 里3.0的cdc还是支持原来的通过手动写代码用ds方式来监听吧?不通过配置文件,oracle的监听。
参考答案:
支持的。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/602837
问题三:Flink CDC oracle-cdc-3.0-snapshot这个没在maven仓库找到怎么找?
Flink CDC 里oracle-cdc-3.0-snapshot这个没在maven仓库找到。在哪里下的?
参考答案:
可以直接用。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/602836
问题四:Flink CDC 里mysql的cdc出来的json op字段有哪几种值?是 c r u d 吗?
Flink CDC 里mysql的cdc出来的json op字段有哪几种值?是 c r u d 吗?
参考答案:
有r的,initial的时候。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/602831
问题五:请问 flink cdc可以处理doris 数据吗?
请问 flink cdc可以处理doris 数据吗?
参考答案:
Flink Doris Connector
本文档适用于flink-doris-connector 1.1.0之后的版本,1.1.0之前的版本参考这里
Flink Doris Connector 可以支持通过 Flink 操作(读取、插入、修改、删除) Doris 中存储的数据。
代码库地址:https://github.com/apache/doris-flink-connector
可以将 Doris 表映射为 DataStream 或者 Table。
注意:
修改和删除只支持在 Unique Key 模型上
目前的删除是支持 Flink CDC 的方式接入数据实现自动删除,如果是其他数据接入的方式删除需要自己实现。Flink CDC 的数据删除使用方式参照本文档最后一节
参考https://doris.apache.org/zh-CN/docs/1.2/ecosystem/flink-doris-connector/
关于本问题的更多回答可点击进行查看: