这是一个创建于 1495 天前的主题，其中的信息可能已经有所发展或是发生改变。
看文档说，集群消费模式下，默认采用平均分配策略，如果一个 group 下 consumer 数量大于 queue 的数量，多出来的 consumer 将不会分配对应的 queue，也就是无法消费
那么在生产环境下，一个应用的 pod 数可能会远大于 RocketMQ 的 queue 数量，这是不是会存在很大的浪费问题，另外如果出现 mq 消费堆积，能怎么解决呢
 |
1
Jooooooooo 2020-10-31 18:10:37 +08:00
kafka 也有类似的问题.
我们的解决方案是改成了轮询拉取模式, 虽然不是很优雅. 但能解决有几百个机器只有一小部分能消费的问题. |
 |
2
lry OP @Jooooooooo 这样改是不是放弃了自带的 Rebalance ？这个轮询是指 单个 consumer 轮询拉取 所有的 queue，还是 单个 queue 同时分配了多个 consumer，这几个 consumer 轮询去拉取指定的 queue ？这两者好像都不太好维护 queue 的 offset 持久化，不知是怎么解决的？😅
|
 |
3
aqqwiyth 2020-10-31 19:20:18 +08:00
1.在 broker 创建 topic 的时候修改 queue 的大小.
2.producer 第一次发送的时候也可以配置 queue 的大小. 3.扩容 broker 4.更换一个 topic. 使用新的 topic 加大 queuesize 如果你的消费速度比产生速度还快. 第 4 个是靠谱的 |
 |
4
billlee 2020-10-31 20:36:56 +08:00
多加分区吧，没用过 rocketmq, 但对 kafka 来说几百个分区完全是正常操作
|
 |
5
hpeng 2020-10-31 21:43:35 +08:00
如果能扩的话，就用 3 楼方法扩，不能扩，消费者多于 queue 就是浪费了。堆积的话，不是还有消费线程数可以调么。调整也解决不了，就是这个 queue 数量都不满足你们的要求了，就要么就扩，换其他的 mq 也会有类似问题的。
|
Select Language