Apache RocketMQ这个问题有人遇到过吗?

consumer重启后 ,之前的clientid 控制台上还在 ,导致重启后只能订阅到一半的queue ,这个有人遇到过吗?

展开
收起
wenti 2023-02-06 14:33:55 193 分享 版权
2 条回答
写回答
取消 提交回答
  • 可能是订阅关系不一致,您可以参考一下这个链接,应该有您想要的回答:https://blog.csdn.net/datastructure18/article/details/128115883——该回答整理自钉群“群1-Apache RocketMQ 中国开发者钉钉群”

    2023-02-06 19:15:17
    赞同 展开评论
  • 我觉得原因可能是当 Consumer 重启后,之前使用的 Client ID 可能仍然存在,造成控制台显示的 Consumer 存在重复的情况。

    我帮你找到的解决这个问题的方法有:

    手动在控制台上删除重复的 Consumer。

    在代码中设置不同的 Client ID,以避免 Consumer 重启后出现重复的情况。

    使用 RocketMQ 自带的自动删除机制,它可以自动删除不活动的 Consumer。

    2023-02-06 15:15:02
    赞同 展开评论

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

收录在圈子:
+ 订阅
阿里云 云原生应用平台 肩负阿里巴巴集团基础设施云化以及核心技术互联网化的重要职责,致力于打造稳定、标准、先进的云原生产品,成为云原生时代的引领者,推动行业全面想云原生的技术升级,成为阿里云新增长引擎。商业化产品包括容器、云原生中间件、函数计算等。
还有其他疑问?
咨询AI助理