[
https://issues.apache.org/jira/browse/ROCKETMQ-309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16255252#comment-16255252
]
ASF GitHub Bot commented on ROCKETMQ-309:
-----------------------------------------
zhouxinyu commented on issue #190: [ROCKETMQ-309] Add new consumer implement
URL: https://github.com/apache/rocketmq/pull/190#issuecomment-344915266
Yes, It's exactly expected, `CONSUME_FROM_LAST_OFFSET` only take effect at
the first subscription action of the consumer, you can reset the offset of
stale consumers by `mqadmin` tool.
Consume from the last offset for each restart isn't common.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> add new consumer implement
> --------------------------
>
> Key: ROCKETMQ-309
> URL: https://issues.apache.org/jira/browse/ROCKETMQ-309
> Project: Apache RocketMQ
> Issue Type: New Feature
> Components: rocketmq-client
> Affects Versions: 4.1.0-incubating
> Reporter: laiyiyu
> Assignee: yukon
> Priority: Trivial
> Labels: add, consumer, implement, new
>
> When application use consume client in Broadcast model which runs in the
> docker,we can pull message only from fist offset, because docker allocate the
> apps at random and cause the store file do not reuse. However, we only want
> to pull message from last offset sometimes even though the apps runs in the
> docker, and we can use MQBroadcastFromLastConsumer in this case.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
