flink中处理kafka分区的消息顺序

2023-12-13 17:34:24

背景

kafka分区的消息是有序的，那么flink在消费kafka分区的时候消息的顺序是怎么样的呢？还能保持这个有序性吗，本文就来记录下

flink消费kafka分区的顺序性

在这里插入图片描述

从上图可知，flink的转换算子比如map，flatMap，fliter等处理消息时是有序进行的，也就是此时消息的分区顺序性依然得到维护，这意味着你可以基于前后消息的顺序来做一些判断逻辑，但是当经过keyed by等分组算子后，消息的顺序性就不会被保证了

文章来源:https://blog.csdn.net/lixia0417mul2/article/details/134842993
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。