请教一个问题,参考下列我疑惑的是这个flink cdc+kafka同步数据的流程是否正确呢?[阿里云实时计算 Flink版]

请教一个问题,现在要实现将mysql的数据实时同步到starrock中。 我是采用flink cdc+kafka进行同步 现在我是首先使用flink cdc同步mysql的数据到kafka,然后再通过cdc消费kafka的数据同步到starrock中。 这样同步的话,假设我要同步一张表,我要使用flink sql创建2个任务进行同步。 第一个任务是将Mysql同步到kafka 第二个任务是将kafka同步到starrock 我疑惑的是这个flink cdc+kafka同步数据的流程是否正确呢?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====