如何在 flink cdc 中保持 sink 顺序

问题描述 投票:0回答:0

想用flink cdc消费更新后的mysql数据,想sink到其他表,不知道是否保持更新顺序。例如:

update1:更新表set id=2 where id=1; update2:更新表 set id=3 where id=2; update3:更新表 set id=4 where id=3;

如果我设置sink parallelism = 3,它能保持update1,update2,update3的顺序吗,或者我应该怎么做才能保持consume的顺序

apache-flink flink-streaming cdc
© www.soinside.com 2019 - 2024. All rights reserved.