各位大佬，我想问下RocketMQ5.0里面新增的pop消费模型具体实现细节，pop出一条消息之后，等待ack消息返回，如果收到ack消息之后，移除buffer中的checkpoint信息，更新消费进度。多个消费者去消费同一个topic下的同一个Queue，如果先获取到消息的消费者，因为外在因素导致ack消息是晚于其他消费者的，那这个消费进度是咋更新的？ pop模型的这个消费进度的更新有点没太理解，像push模型消费完消息之后，客户端会将topic下Queue的消费偏移量发送到broker保存落盘，只不过push模型下，如果存在多个线程消费耗时不一样的情况，是获取的最小的那个偏移量，比如是：线程1消费的是1-10的消息，线程2消费的是11-20，线程3是21-30，线程1和3消费完成了，则会把线程1的最大偏移量作为保存点
因为外在因素导致ack消息是晚于其他消费者的，那这个消费进度是咋更新的？[阿里云容器服务Kubernetes版]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！