可以使用mqadmin中的resetOffsetByTime命令来跳过某一个时间点之前的消息。 这样就把老的消息跳过了。
虞开元 <yukaiy...@qiyi.com> 于2018年6月13日周三 下午4:17写道： > > 这个问题我之前有提交过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 > > -- ==================== best regards 卢松
