因为外在因素导致ack消息是晚于其他消费者的，那这个消费进度是咋更新的？
各位大佬，我想问下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的最大偏移量作为保存点
展开
收起
1
条回答
写回答
写回答
-
也有进度， 只是这个进度是broker根据client ack后自己算的，这种逻辑从client 到 broker了，1消息如果太久没有ack， 就会重试， 进入重试队列。 此时normal topic中下一个应该被消费的消息是4（此答案整理自群2-Apache RocketMQ 中国开发者钉钉群）2022-09-29 11:05:56赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
热门讨论
热门文章
怎么查看registry.aliyuncs.com/google_containers都有哪些镜像
7816
registry.aliyuncs.com/google_containers这个镜像仓库都有啥镜像
1643
ACS与ACK Serverless 两个产品的区别
39
服务 和 容器 是什么关系
6059
阿里云发布的全球首个容器计算服务ACS，和已有的ASK有什么区别
1188
容器服务ACK的k8s的出口IP地址在哪里看来着？
506
容器服务ACK的节点机，磁盘空间被占满，直接使用crictl清理不用的镜像会影响kubelet么？
485
K8S 集群 ingress资源的ADDRESS怎样配置为多个工作节点的IP？
682
权限在Docker容器内被拒绝无法创建目录怎么办？
3134
Linux中的base 容器的参数enabled和gpgcheck的含义分别是什么？
5252
展开全部
Docker 镜像加速器
406343
Docker CE 镜像源站
438344
Minikube - Kubernetes本地实验环境
234366
容器镜像服务 Docker镜像的基本使用
52035
利用Helm简化Kubernetes应用部署
40294
利用Docker和阿里云容器服务轻松搭建TensorFlow Serving集群
32164
Docker Engine 镜像源站
44252
阿里云容器服务-高可用Kubernetes部署指南
27668
阿里云容器服务飞天敏捷版详解
27026
免费的容器架构可视化工具 | 阿里云应用高可用服务 AHAS 发布重大新特性
21773
展开全部
