RocketMQ consumer 数量和 queue 数量的关系

[lry]

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

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

[Jooooooooo]

kafka 也有类似的问题.

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

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

[lry]

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

[aqqwiyth]

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


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

[billlee]

多加分区吧，没用过 rocketmq, 但对 kafka 来说几百个分区完全是正常操作

[hpeng]

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

[lry]

@aqqwiyth @billlee @hpeng 明白了 多谢。