ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET

来源:5-2 核心配置参数讲解

_LJ

2019-09-09

设置了ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET,为什么还会从topic的第一个消息开始消费呢?
老师这里说的是
当启动了一次consumer后,它后续会有一个消息的消费,我们consumer消费的offset会上报到broker,那这样我的consumer如果再启动的话,就会从上次所消费的进度去开始
没有太懂,这个问题和答案好像没有什么关系

写回答

1回答

阿神

2019-09-12

你可以多试试,设置last配置应该是可以做到offset从最后的位置开始消费的,有时候可能会有多次消费的情况,不保证一定是,因为幂等性需要consumer自己来做,也就在于consumer重启加入的时候可能会有类似这个问题,所以做好消费端幂等即可

0
0

RocketMQ核心技术精讲与高并发抗压实战

理论+实战,系统掌握RocketMQ核心技术, 挑战高并发抗压实战

1182 学习 · 304 问题

查看课程