一个主题有 4 个队列,只使用一个队列

  • 本文关键字:队列 一个 java rocketmq
  • 更新时间 :
  • 英文 :


有一些 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 个队列
  • 检查规则:一个消费者组内的所有消费者实例必须具有相同的发布订阅(消费者组主题标签必须相同,否则队列不能正确分配(

相关内容

  • 没有找到相关文章

最新更新