消息队列RocketMQ版消费者堆积负载不均是什么原因?

消息队列RocketMQ版消费者堆积负载不均是什么原因?

展开
收起
Lee_tianbai 2021-01-01 16:17:38 1333 分享 版权
1 条回答
写回答
取消 提交回答
  • 【问题原因】: 这个是分配策略,当所有消费实例都达到消费能力上限后,不再完全分配到所有 都队列,会集中分配到前面的队列。这种现象一般建议提升代码消费能力和增加消费 实例数解决堆积问题后就不会出现这种堆积。 可以理解为消费能力已经饱和,其他队列本身也有堆积情况,那么饱和之后分配 就会直接到指定的某个队列。这种情况需要增加消费者或者优化代码来提升能力减少 堆积,堆积多肯定会更加满负荷在跑。 这个上限不是挤压的或者 mq 端大量堆积导致程序高负载运行的上限,是正常消 费有堆积就认为达到上限,是一个正常消费的理论上限。 这个是产品侧的一个策略,无法做到堆积后再均衡对堆积量做进一步对均衡分 配。建议增加消费实例或者优化代码,减少堆积压力。

    2021-01-01 16:17:58
    赞同 展开评论

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

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