You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@rocketmq.apache.org by 萨尔卡 <10...@qq.com> on 2018/06/10 09:01:02 UTC
CONSUME_FROM_LAST_OFFSET issue
hi budies,
i have a new consumer group, and set ConsumeFromWhere=CONSUME_FROM_LAST_OFFSET.
hope it would consume from the last offset that other old consumer group did. but offset=0 alway i got, dont ignore historical messages,
client code getting offset:
broker get the offset request,
ConsumeFromWhere
When a new Consumer Group is established, it will need to decide whether it needs to consume the historical messages which had already existed in the Broker. CONSUME_FROM_LAST_OFFSET will ignore the historical messages, and consume anything produced after that. CONSUME_FROM_FIRST_OFFSET will consume every message existed in the Broker. You can also use CONSUME_FROM_TIMESTAMP to consume messages produced after the specified timestamp.
------------------
Have a nice dayFrancis Lee
QQ : 1026203200
Re: CONSUME_FROM_LAST_OFFSET issue
Posted by Zhanhui Li <li...@gmail.com>.
萨尔卡你好,
每个Consumer Group之间的Offset都是独立的. 新的Consumer Group如果想从另一个Consumer Group的Offset开始, 可以使用cloneGroupOffset这个命令, 运维的方式设置.
使用方法, 可以通过 bash mqadmin cloneGroupOffset -h方式获得.
祝使用愉快.
李战辉
> 在 2018年6月10日,下午5:01,萨尔卡 <10...@qq.com> 写道:
>
>