有一些RocketMQ主题，但只有一个主题有4个队列，只能消费1个队列。
RocketMQ 4.2.0 Java 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 个队列
- 检查规则:一个consumer-group中的所有consumer-instances必须具有相同的pub-sub(consumerGroup-topic-tag必须相同，否则无法正确分配队列)
关于java - 1个Topic有4个队列，只能消费1个，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/57787814/