"RocketMQ中这种不一致的情况,会影响消费, 我们现在的情况是同一个topic的消息, 部分消息消费不到云产品版本: 5.x客户端: 4.9不一致,是因为在不同阶段链接了MQ服务。
"
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
您好,RocketMQ中 consumerOffset 与 brokerOffset 不一致是比较常见的问题,主要有以下几种情况:
客户端消费消息失败后,未提交消费进度。
Broker 宕机后,未将 consumerOffset 同步到 ZK 或其它备份节点。
Broker 配置的 consumerOffsetCheckIntervalMs 时间间隔过长。
如果您遇到这种情况,可以尝试以下解决方案:
检查客户端日志,确认是否有消费消息失败的情况。
检查 Broker 日志,确认是否有 Broker 宕机的情况。
检查 Broker 的 consumerOffsetCheckIntervalMs 配置,建议将该参数设置为 1000 或更小。
如果您按照以上步骤仍然无法解决问题,可以通过 RocketMQ 官方社区 提交反馈。
感谢您的支持!
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系列产品 Serverless 化。RocketMQ 中文社区:https://rocketmq-learning.com/