最近学习Flink CDC,有个场景不知道如何满足。如何做到控制不同Source执行顺序,我这边希望先从CDC读取存量的配置信息,读取完成后再从Kafka消费业务数据
Flink有办法控制CDC读取完存量数据后kafkaSource开始消费吗[阿里云实时计算 Flink版]
「点点赞赏,手留余香」
还没有人赞赏,快来当第一个赞赏的人吧!
最近学习Flink CDC,有个场景不知道如何满足。如何做到控制不同Source执行顺序,我这边希望先从CDC读取存量的配置信息,读取完成后再从Kafka消费业务数据