1

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);

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

4

1 回答 1

0

检查两件事：

  • 检查您是否向一个队列发送了一些有序的消息。其他人空着。所以你只能消耗 1 个队列
  • 检查规则：all-consumer-instances in-one-consumer-group 必须有相同的 pub-subs（consumerGroup-topic-tag 必须相同，否则无法分配队列）
于 2019-11-02T10:10:30.880 回答