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

Posted to issues@rocketmq.apache.org by "Jaskey Lam (JIRA)" <ji...@apache.org> on 2017/02/16 05:06:42 UTC

[jira] [Created] (ROCKETMQ-102) Offet Persisted is not the latest consumed message

Jaskey Lam created ROCKETMQ-102:
-----------------------------------

             Summary: Offet Persisted is not the latest consumed message
                 Key: ROCKETMQ-102
                 URL: https://issues.apache.org/jira/browse/ROCKETMQ-102
             Project: Apache RocketMQ
          Issue Type: Improvement
          Components: rocketmq-client
            Reporter: Jaskey Lam
            Assignee: Xiaorui Wang


When shutdown push consumer, push consumer will shutdwon thread pool then persist offset.

While shutdown thread pool is only stop submiting message to consume, which does not stop consuming message which exists in the the thread queue or is already being consumed.

Which will cause repeated message very easily though user are shutdown gracefully according to the provided interface.

A way to solve this problem is needed. Such as accpet a param that how long to wait for thread pool to terminated.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)