请教一下Flink写入SR并行度的问题


看这边的描述,多并行度情况下需要考虑保证数据有序性,如果kafka中的数据是有序的,这边如果配置多并行度,写入SR会导致乱序吗

这个有大佬知道么

参考下这个使用手册 里面有并发的推荐和注意事项https://forum.mirrorship.cn/t/topic/4972

大佬,我想知道的是,多并行度可能导致数据写入SR乱序吗?

https://blog.csdn.net/qq_33705071/article/details/130584928

我认为理论上是可能乱序的。
生产者将数据写入到kafka多个分区中,也只能保证单分区有序,之后再从kafka分区消费,应该是会出现乱序问题的,一般后道flink处理的时候都会通过窗口延迟关闭来解决乱序问题。
总之,我认为是会出现乱序问题,一般是后面进行解决,如果你仅仅导入starrock进行离线计算,我感觉这个问题不会影响你,如果是实时计算,可能要考虑这个问题,可以按照createTime进行排序什么的。