1

版本:3.2.6

消费者类型:PullConsumer

当一个新的消费者启动时,我将尝试从 mq 获取消费者偏移量:

long offset = pullConsumer.fetchConsumeOffset(mq, true) ;

但我碰巧遇到这个返回-1,我看到了错误:

CODE: 22 Not found, V3_0_6_SNAPSHOT maybe this group consumer boot first

从错误日志。

4

1 回答 1

0

这只发生在一个全新的消费者组以以下任一情况启动

  1. min offset >0 ,表示该主题是旧主题/队列,之前已从该队列中删除了哪些消息。

  2. 消费偏移量为 0 的消息被认为是从磁盘消费checkInDiskByCommitOffset,rocketmq 认为如果你从 0 消费,很多消息将从磁盘消费,而不是从页面缓存中消费。

发生这种情况时,客户应负责确定在哪里消费。可能从 0 开始,但您可能会从磁盘消耗大量消息。

于 2016-11-10T13:28:28.653 回答