公司要建立实时数仓，准备flink+starrocks

[U_1653644474324_2809]

公司准备建立实时数仓，要用flink+starrocks架构，想通过flink-connector-mysql-cdc读取mysql数据，然后插入到starrocks，代码怎么写的？我百度了很久，很少有代码，如何实现端到端的一致性，能给点测试代码吗？想做下测试

[yuchen1019]

https://docs.starrocks.com/zh-cn/main/loading/Flink_cdc_load 参考这里的官方文档，里面有对应的文件