RocketMQ中这种不一致的情况,会影响消费,怎么解决?

"RocketMQ中这种不一致的情况,会影响消费, 我们现在的情况是同一个topic的消息, 部分消息消费不到云产品版本: 5.x客户端: 4.9不一致,是因为在不同阶段链接了MQ服务。
037c63a4e08a9529a1a8b2665775e9c2.png
"

展开
收起
十一0204 2023-08-15 23:36:20 399 分享 版权
1 条回答
写回答
取消 提交回答
  • 您好,RocketMQ中 consumerOffset 与 brokerOffset 不一致是比较常见的问题,主要有以下几种情况:

    客户端消费消息失败后,未提交消费进度。
    Broker 宕机后,未将 consumerOffset 同步到 ZK 或其它备份节点。
    Broker 配置的 consumerOffsetCheckIntervalMs 时间间隔过长。
    如果您遇到这种情况,可以尝试以下解决方案:

    检查客户端日志,确认是否有消费消息失败的情况。
    检查 Broker 日志,确认是否有 Broker 宕机的情况。
    检查 Broker 的 consumerOffsetCheckIntervalMs 配置,建议将该参数设置为 1000 或更小。
    如果您按照以上步骤仍然无法解决问题,可以通过 RocketMQ 官方社区 提交反馈。

    感谢您的支持!

    2023-09-27 17:47:28
    赞同 展开评论

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系列产品 Serverless 化。RocketMQ 中文社区:https://rocketmq-learning.com/

还有其他疑问?
咨询AI助理