开发者社区 > 云原生 > 云消息队列 > 正文

消息队列RocketMQ版重置消费位点失败是什么原因?

重试消费者的消费位点没有效果,还是有许多堆积。

展开
收起
Lee_tianbai 2021-01-01 16:46:04 1694 0
1 条回答
写回答
取消 提交回答
    1. 确认是否为集群消费(因广播模式下,消费位点都由客户端本地维护,因此 广播消费模式下不支持重置消费位点)。
    2. 确认当前消费者是否在线,消费者必须在线才能重置消费位点。
    3. 确认 sdk 版本,sdk 版本过低也会导致此问题。(建议升级 sdk, 至少是 1.8.0 版本。
    4. 可以点击单个 c 端的详情查看当前消费者当中的消息是否是在重试队列当中 的,如果选择的是清除所有堆积消息,从最新位点开始消费方式重置消费位 点,是不能清除重试队列里的消息的。这个时候可以选择使用按时间点进行消费位点重置方式进行重置,此方式没有这个限制。
    2021-01-01 16:46:23
    赞同 展开评论 打赏

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关产品

  • 云消息队列 MQ
  • 相关电子书

    更多
    企业互联网架构之消息队列 立即下载
    基于消息队列RocketMQ的大型分布式应用上云最佳实践 立即下载
    云原生消息队列Apache RocketMQ 立即下载