有一些 RocketMQ 主题,但只有一个主题有 4 个队列,只消耗一个队列。
火箭MQ 4.2.0 爪哇 1.8
消费组配置:
depthConsumerGroup.setNamesrvAddr(rocketMQConfig.getNameServers());
depthConsumerGroup.setConsumeThreadMin(64);
depthConsumerGroup.setConsumeThreadMax(128);
depthConsumerGroup.setAdjustThreadPoolNumsThreshold(500);
depthConsumerGroup.setMessageModel(MessageModel.CLUSTERING);
depthConsumerGroup.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET);
当我重置主题时间戳并重新启动应用程序时。将使用所有队列。但是运行一段时间,只会消耗一个队列。
检查两件事:
- 检查您是否向一个队列发送了一些有序的消息。 其他人是空的。所以你只能消耗 1 个队列
- 检查规则:一个消费者组内的所有消费者实例必须具有相同的发布订阅(消费者组主题标签必须相同,否则队列不能正确分配(