hi 对于 kafka 来说,单 partition 内的消息可以保证顺序,但是 partition A 和 partition B 之间的消息顺序是没法保证的。
Best, Congxian On Mar 5, 2019, 18:35 +0800, 刘 文 <[email protected]>, wrote: > 请教一下,大家说的Flink 乱序问题,是什么情况下产生,我没明白? > ).谁给我一下会产生乱序问题的场景吗? > ).以下是读取kafka中的数据,三个并行度 > ).输出的结果如下:(总数据20条) > > 3> Message_3 > 1> Message_1 > 2> Message_2 > 1> Message_4 > 2> Message_5 > 3> Message_6 > 2> Message_8 > 1> Message_7 > 2> Message_11 > 3> Message_9 > 2> Message_14 > 1> Message_10 > 2> Message_17 > 3> Message_12 > 2> Message_20 > 1> Message_13 > 3> Message_15 > 1> Message_16 > 3> Message_18 > 1> Message_19
