消费者服务重启后,同一个topic又开始重头消费了

[fengylm]

一个topic消费了N条数据后,当重启消费者后,又从第一条开始重新消费了,是我配置的有问题么,配置代码如下

如果增加配置 FromLastOffset=true后就只会送最新的开始,历史没有处理的就直接不管了,有没有配置可以指定从上次消费的offset开始继续消费的?

[nnhy]

对于rocketmq来说，服务器会记录每个消费组最后一次消费偏移量。
NewLife.RocketMQ启动的时候，会查询消费组在每一个queue队列上的偏移量，然后从该位置开始消费数据。

如果每次都从最早的一条消息来消费，有可能是客户端启动时未能获取上次偏移量，客户端服务端版本不一致时就可能发生这个问题。
你可以调试代码，获取和设置偏移量的地方。

[fengylm]

确实版本不一致 我重新装个低版本的库试试

[nnhy]

目前没有测试过 rocketmq5.0，有的朋友说能用，有的朋友说不能用。
我在公司用的是 4.x

[nnhy]

这个问题，可能跟另一个有关。阿里云公网消费有缺陷。

#77