You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@rocketmq.apache.org by "laiyiyu (JIRA)" <ji...@apache.org> on 2017/11/03 02:48:00 UTC

[jira] [Commented] (ROCKETMQ-309) add new consumer implement

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