问题一:Flink CDC中datax增量同步,是不是用jdbc连接,然后用select语句去查?
Flink CDC中datax增量同步,是不是用jdbc连接,然后用select语句去查?
参考答案:
是的,但是每个表要有一个last_update_time 字段,不然无法做到增量datax同步. 原理就是使用select * from xxx where last_update_time > ?
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/581852
问题二:Flink CDC中flink sql client 可以用yarn applicaiotn部署吗?
Flink CDC中flink sql client 可以用yarn applicaiotn部署吗?
参考答案:
可以,目前开源的比较推荐是dinky,他有整库同步,然后就是stream park,付费的就是阿里云的vvr了
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/581851
问题三:如何优化flinkcdc初始化大表呀?
如何优化flinkcdc初始化大表呀,我有一张千万大表初始化cdc,非常慢,每秒才100多条,因为给客户演示,目前这个情况很难过关?
参考答案:
如果是sql慢的话可以用api
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/581849
问题四:Flink CDC中mysql有个blob字段,是压缩后在写入的,这种怎么解析到kafka?
Flink CDC中mysql有个blob字段,是压缩后在写入的,这种怎么解析到kafka?
参考答案:
debezium.binary.handling.mode这个用base64可以转string,然后再from_base64,但是那种压缩的转不出来,只有那种不压缩的可以
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/581847
问题五:flinkcdc3.0支持全库备份了吗?
flinkcdc3.0支持全库备份了吗?
参考答案:
是的
关于本问题的更多回答可点击进行查看: