Guys, the test in the idea uses FlinkCDC SQL to read Mysql data and write it into Kafka. The code creates

2022-08-10 05:00:00 【Alibaba Cloud Q&A】

Everyone, I use FlinkCDC SQL to read Mysql data and write it into Kafka in the test in idea. A checkpoint is created in the code. It is found that every time I restart the code of FlinkCDC in Idea, Mysql data will be read in full and written to Kafka. Please tell meHow to incrementally read Mysql data and write it to Kafka?Does the Mysql data read in full every time the program is restarted?

原网站

版权声明
本文为[Alibaba Cloud Q&A]所创，转载请带上原文链接，感谢
https://yzsam.com/2022/222/202208031351025778.html

当前位置：网站首页>Guys, the test in the idea uses FlinkCDC SQL to read Mysql data and write it into Kafka. The code creates

Guys, the test in the idea uses FlinkCDC SQL to read Mysql data and write it into Kafka. The code creates

边栏推荐

猜你喜欢

随机推荐