java - 1个Topic有4个队列，只能消费1个

Question

有一些RocketMQ主题，但只有一个主题有4个队列，只能消费1个队列。

RocketMQ 4.2.0Java 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);

当我重置主题时间戳并重新启动应用程序时。所有队列都会被消耗。但是运行一段时间，只有一个队列会被消耗。

Answer 1

检查两件事:

• 检查您是否向一个队列发送了一些有序的消息。其他人空着。所以你只能消耗 1 个队列
• 检查规则:一个consumer-group中的所有consumer-instances必须具有相同的pub-sub(consumerGroup-topic-tag必须相同，否则无法正确分配队列)