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

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

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

    评论

    全部评论 (0)

    登录后可评论

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

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

你好,我是AI助理

可以解答问题、推荐解决方案等