Mr-稻帅 2023-02-24 15:18 采纳率: 0%
浏览 10

关于#rocketmq#的问题,如何解决?

有知道单机版的rocketmq(一个nameserver,一个broker),topic默认的是4个队列,消费端配置为CLUSTERING(集群)模式,topic下面有部分队列的消息消费不到,有知道这个是什么原因吗?

img

有知道单机版的rocketmq(一个nameserver,一个broker),topic默认的是4个队列,消费端配置为CLUSTERING(集群)模式,topic下面有部分队列的消息消费不到,有知道这个是什么原因吗?

  • 写回答

2条回答 默认 最新

  • RPJ_99 2023-02-24 15:42
    关注

    RocketMQ中一个Topic默认有4个队列,但是这并不意味着每个队列都会被消费者消费。可能存在以下原因导致部分队列的消息无法被消费:

    1. 消费者配置问题:消费者配置不正确,例如消费者组名称不一致,消费者实例名称相同等。在这种情况下,消费者只会消费其中一部分队列,而其他队列的消息则无法被消费。

    2. 消费者负载均衡策略:消费者的负载均衡策略可能会导致部分队列的消息无法被消费。默认情况下,消费者使用轮询负载均衡策略,但是如果某些消费者实例的消费速度比其他实例慢,那么消息可能会被分配到这些实例上,从而导致部分队列的消息无法被消费。

    3. Broker宕机:如果其中一个Broker宕机了,那么部分队列的消息就无法被消费。

    4. 未正确发送消息:如果生产者未正确发送消息,则部分队列可能没有消息。

    建议检查以上因素,以确定为什么消息没有被消费。可以通过查看消费者日志、Broker日志、RocketMQ控制台等方式进行排查。

    评论

报告相同问题?

问题事件

  • 修改了问题 2月24日
  • 创建了问题 2月24日

悬赏问题

  • ¥15 程序不包含适用于入口点的静态Main方法
  • ¥15 素材场景中光线烘焙后灯光失效
  • ¥15 请教一下各位,为什么我这个没有实现模拟点击
  • ¥15 执行 virtuoso 命令后,界面没有,cadence 启动不起来
  • ¥50 comfyui下连接animatediff节点生成视频质量非常差的原因
  • ¥20 有关区间dp的问题求解
  • ¥15 多电路系统共用电源的串扰问题
  • ¥15 slam rangenet++配置
  • ¥15 有没有研究水声通信方面的帮我改俩matlab代码
  • ¥15 ubuntu子系统密码忘记