这个问题我之前有提交过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