Re: 回复: CONSUME_FROM_LAST_OFFSET issue

2018-06-13 Thread 卢松
Sent: Wednesday, June 13, 2018 2:02 PM > To: users ; lusong19860829 > > Subject: 回复: CONSUME_FROM_LAST_OFFSET issue > > > > 非常感谢你的解释。目前rocketmq处理如下功能是放在一起的, 才导致了第一条总是从0开始消费。 > > 如果需要实现如下功能, 你有啥意见和建议: > > > > 1. 新上线的消费者组从上线时,topic中收到的那条消息开始消费 > > 2. topic扩容时, 连接到

RE: 回复: CONSUME_FROM_LAST_OFFSET issue

2018-06-13 Thread 虞开元
这个问题我之前有提交过patch,有需要可以参考一下。 https://issues.apache.org/jira/browse/ROCKETMQ-248 虞开元 From: 萨尔卡 <1026203...@qq.com> Sent: Wednesday, June 13, 2018 2:02 PM To: users ; lusong19860829 Subject: 回复: CONSUME_FROM_LAST_OFFSET issue 非常感谢你的解释。目前rocketmq处理如下功能是放在一起的, 才导致了第一条总是从0开始消费。 如果需要实现如下功能, 你有

?????? CONSUME_FROM_LAST_OFFSET issue

2018-06-12 Thread ??????
??rocketmq?? 0?? ?? ?? 1. ??topic 2. topic ??queue??group0 -- Have a nice dayFrancis Lee

Re: CONSUME_FROM_LAST_OFFSET issue

2018-06-11 Thread 卢松
关于CONSUME_FROM_LAST_OFFSET在新消费组中不起作用的问题,我有个文章详细说明了。 https://mp.weixin.qq.com/s/XjNjE_Hwg9WLPiInSuPMYw 文章中有图片。 以前碰到过一个问题,一个新消费组上线时和我们期望的消费行为有偏差,今天专门研究下这个问题,看看是怎么回事。 在RocketMQ中,假如一个新消费组订阅了几个topic,按正常人或者正常业务的期望,新消费组应该从订阅topic的最后一个消息开始消费,但是实际情形不是如此,有时候新消费组会从这些topic的开头开始消费。这就是新消费组上线的风险点。 这对业务来

?????? CONSUME_FROM_LAST_OFFSET issue

2018-06-11 Thread ??????
hi zhanhui, CONSUME_FROM_LAST_OFFSET?? Consumer Group??Topic topic??200??group??201 ??group. ?? -- Have a nice dayFrancis Lee QQ

Re: CONSUME_FROM_LAST_OFFSET issue

2018-06-10 Thread Zhanhui Li
萨尔卡你好, 每个Consumer Group之间的Offset都是独立的. 新的Consumer Group如果想从另一个Consumer Group的Offset开始, 可以使用cloneGroupOffset这个命令, 运维的方式设置. 使用方法, 可以通过 bash mqadmin cloneGroupOffset -h方式获得. 祝使用愉快. 李战辉 > 在 2018年6月10日,下午5:01,萨尔卡 <1026203...@qq.com> 写道: > >