tongchenkeji 发表于：2022-8-26 10:11:060次点击 已关注取消关注 关注 私信 大佬们，请问个问题，flink 多个并行消费rabbitmq消息，怎么保证顺序消费[阿里云实时计算 Flink版] 暂停朗读为您朗读 大佬们，请问个问题，flink 多个并行消费rabbitmq消息，怎么保证顺序消费 「点点赞赏，手留余香」 赞赏 还没有人赞赏，快来当第一个赞赏的人吧！ 海报 实时计算Flink版# 云消息队列 MQ1430# 实时计算 Flink版3179# 流计算2236# 消息中间件1371
认真学习的heartAM 2023-11-27 18:18:21 3 可以使用Flink的Partitioner功能。 Partitioner可以将消息按照指定的规则进行分区，从而保证消息按照指定的顺序进行消费。您可以根据消息的ID或者其他唯一标识符来进行分区，从而保证消息的顺序消费。
flink的分区可以区分多个并行的，应该可以满足。
楼主你好，flink的Partitioner可以满足你的需求，使用它通过指定的规则进行分区操作。
可以使用Flink的Partitioner功能。
Partitioner可以将消息按照指定的规则进行分区，从而保证消息按照指定的顺序进行消费。您可以根据消息的ID或者其他唯一标识符来进行分区，从而保证消息的顺序消费。