背景 kafka分区的消息是有序的,那么flink在消费kafka分区的时候消息的顺序是怎么样的呢?还能保持这个有序性吗,本文就来记录下 flink消费kafka分区的顺序性 从上图可知,flink的转换算子比如map,flatMap,fliter等处理消息时是有序进行的,也就是此时消息的分区顺序性依然得到维护,这意味着你可以基于前后消息的顺序来做一些判断逻辑,但是当经过keyed by等分组算子后,消息的顺序性就不会被保证了