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)
