RocketMQ consumer 数量和 queue 数量的关系

看文档说,集群消费模式下,默认采用平均分配策略,如果一个 group 下 consumer 数量大于 queue 的数量,多出来的 consumer 将不会分配对应的 queue,也就是无法消费

那么在生产环境下,一个应用的 pod 数可能会远大于 RocketMQ 的 queue 数量,这是不是会存在很大的浪费问题,另外如果出现 mq 消费堆积,能怎么解决呢

相关文章

5 thoughts on “RocketMQ consumer 数量和 queue 数量的关系

  1. kafka 也有类似的问题.

    我们的解决方案是改成了轮询拉取模式, 虽然不是很优雅.

    但能解决有几百个机器只有一小部分能消费的问题.

  2. @Jooooooooo 这样改是不是放弃了自带的 Rebalance ?这个轮询是指 单个 consumer 轮询拉取 所有的 queue,还是 单个 queue 同时分配了多个 consumer,这几个 consumer 轮询去拉取指定的 queue ?这两者好像都不太好维护 queue 的 offset 持久化,不知是怎么解决的?

  3. 1.在 broker 创建 topic 的时候修改 queue 的大小.
    2.producer 第一次发送的时候也可以配置 queue 的大小.
    3.扩容 broker
    4.更换一个 topic. 使用新的 topic 加大 queuesize

    如果你的消费速度比产生速度还快. 第 4 个是靠谱的

  4. 如果能扩的话,就用 3 楼方法扩,不能扩,消费者多于 queue 就是浪费了。堆积的话,不是还有消费线程数可以调么。调整也解决不了,就是这个 queue 数量都不满足你们的要求了,就要么就扩,换其他的 mq 也会有类似问题的。

发表评论

电子邮件地址不会被公开。 必填项已用*标注