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:46:03 UTC

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

laiyiyu created ROCKETMQ-309:
--------------------------------

             Summary: 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


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)