[ 
https://issues.apache.org/jira/browse/ROCKETMQ-309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16237010#comment-16237010
 ] 

laiyiyu commented on ROCKETMQ-309:
----------------------------------

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.

> 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)

Reply via email to