rocketmq - consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET) 没用

Question

我想从最后一个偏移量读取数据，但使用：

consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET)

没有效果。

Answer 1

ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET仅当您的消费者第一次连接到代理时才有效。

您可能想使用sh mqadmin resetOffsetByTime将偏移量重置为现在。更多详情请参考这里。