问题一:Flink CDC用一个mysqlcdcsource读取多个库的多个表,这个是啥问题啊?
Flink CDC用一个mysqlcdcsource读取多个库的多个表,然后他在同步完一个表的历史数据后,就一直在读取binlog,不去同步别的表了,这个是啥问题啊?
参考答案:
不建议一个mysqlcdcsource同时读取多个库的多个表,应为每个数据库独立配置source。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584655
问题二:Flink CDC这个 实现了么?
Flink CDC这个 实现了么?
参考答案:
看下flink3.0介绍. https://ververica.github.io/flink-cdc-connectors/master/
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584654
问题三:Flink CDC中如果一个记录多次变更,如果再统计时,会不会重复多次统计呢?如果会,如何排重呢?
Flink CDC中如果一个记录多次变更,如果再统计时,会不会重复多次统计呢?如果会,如何排重呢?
参考答案:
你设置主键统计就解决这个问题
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584652
问题四:多个2.4的Flink CDC会有debezium冲突怎么解决啊?
多个2.4的Flink CDC会有debezium冲突怎么解决啊?
参考答案:
用2.4.2或者3.0
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584651
问题五:Flink CDC3.0这样修改同步的数据库名字可以吗?
Flink CDC3.0这样修改同步的数据库名字可以吗?
参考答案:
可以的 ,
关于本问题的更多回答可点击进行查看: