GitHub user cserwen edited a comment on the discussion: 集群消费模式下,是否在某些情况下,存在同一个队列被 同一个消费组的 多个消费者消费的情况?
RocketMQ 支持 at-least-once 语义,至少投递一次,不保证只消费一次,然后上述情况是会出现的 - Rebalance 是最终一致,除了服务端主动通知,各个 consumer 会定时查询 Topic 分区信息和消费者信息,来计算自己应该消费的队列 - 除了你提到的这些情况,还可能多个 consumer 的 clientID 一样,然后计算出相同的分区,也会重复,由于 push 默认没有锁的机制,个人认为很难保证同一时间一个队列只有一个消费者消费 - RocketMQ 5.0 支持了 POP 消费,拉取消息时会加锁,因此可以解决这个问题,你可以了解下 GitHub link: https://github.com/apache/rocketmq/discussions/7746#discussioncomment-8139606 ---- This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org