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

回复