[
https://issues.apache.org/jira/browse/ROCKETMQ-309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16237021#comment-16237021
]
laiyiyu commented on ROCKETMQ-309:
----------------------------------
even if the apps do not run in the docker, it also has the problem.
for exmaple ,
the client has consume offset 3, and flush the store file , and the
consumer shutdown .
in the mean while ,the broker offset has increan from 3 to 6;
when the client reboot , it only can consum offset from 3 ,but we
want consum offset 6 only.
> 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: Xiaorui Wang
> 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)
