消息队列RocketMQ版消费者堆积负载不均是什么原因?
【问题原因】: 这个是分配策略,当所有消费实例都达到消费能力上限后,不再完全分配到所有 都队列,会集中分配到前面的队列。这种现象一般建议提升代码消费能力和增加消费 实例数解决堆积问题后就不会出现这种堆积。 可以理解为消费能力已经饱和,其他队列本身也有堆积情况,那么饱和之后分配 就会直接到指定的某个队列。这种情况需要增加消费者或者优化代码来提升能力减少 堆积,堆积多肯定会更加满负荷在跑。 这个上限不是挤压的或者 mq 端大量堆积导致程序高负载运行的上限,是正常消 费有堆积就认为达到上限,是一个正常消费的理论上限。 这个是产品侧的一个策略,无法做到堆积后再均衡对堆积量做进一步对均衡分 配。建议增加消费实例或者优化代码,减少堆积压力。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/