Sent: Wednesday, June 13, 2018 2:02 PM
> To: users ; lusong19860829
>
> Subject: 回复: CONSUME_FROM_LAST_OFFSET issue
>
>
>
> 非常感谢你的解释。目前rocketmq处理如下功能是放在一起的, 才导致了第一条总是从0开始消费。
>
> 如果需要实现如下功能, 你有啥意见和建议:
>
>
>
> 1. 新上线的消费者组从上线时,topic中收到的那条消息开始消费
>
> 2. topic扩容时, 连接到
这个问题我之前有提交过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开始消费。
如果需要实现如下功能, 你有
??rocketmq??
0??
?? ??
1. ??topic
2. topic ??queue??group0
--
Have a nice dayFrancis Lee
关于CONSUME_FROM_LAST_OFFSET在新消费组中不起作用的问题,我有个文章详细说明了。
https://mp.weixin.qq.com/s/XjNjE_Hwg9WLPiInSuPMYw
文章中有图片。
以前碰到过一个问题,一个新消费组上线时和我们期望的消费行为有偏差,今天专门研究下这个问题,看看是怎么回事。
在RocketMQ中,假如一个新消费组订阅了几个topic,按正常人或者正常业务的期望,新消费组应该从订阅topic的最后一个消息开始消费,但是实际情形不是如此,有时候新消费组会从这些topic的开头开始消费。这就是新消费组上线的风险点。
这对业务来
hi zhanhui,
CONSUME_FROM_LAST_OFFSET?? Consumer
Group??Topic
topic??200??group??201
??group.
??
--
Have a nice dayFrancis Lee
QQ
萨尔卡你好,
每个Consumer Group之间的Offset都是独立的. 新的Consumer Group如果想从另一个Consumer Group的Offset开始,
可以使用cloneGroupOffset这个命令, 运维的方式设置.
使用方法, 可以通过 bash mqadmin cloneGroupOffset -h方式获得.
祝使用愉快.
李战辉
> 在 2018年6月10日,下午5:01,萨尔卡 <1026203...@qq.com> 写道:
>
>