这个问题我之前有提交过patch,有需要可以参考一下。
https://issues.apache.org/jira/browse/ROCKETMQ-248


虞开元

From: 萨尔卡 <1026203...@qq.com>
Sent: Wednesday, June 13, 2018 2:02 PM
To: users <users@rocketmq.apache.org>; lusong19860829 <lusong19860...@gmail.com>
Subject: 回复: CONSUME_FROM_LAST_OFFSET issue

非常感谢你的解释。目前rocketmq处理如下功能是放在一起的, 才导致了第一条总是从0开始消费。
如果需要实现如下功能, 你有啥意见和建议:

1. 新上线的消费者组从上线时,topic中收到的那条消息开始消费
2. topic扩容时, 连接到新的queue消费的group能从0开始消费

------------------
Have a nice day
Francis Lee

QQ : 1026203200

Reply via email to