[ https://issues.apache.org/jira/browse/ROCKETMQ-102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895535#comment-15895535 ]
ASF GitHub Bot commented on ROCKETMQ-102: ----------------------------------------- Github user coveralls commented on the issue: https://github.com/apache/incubator-rocketmq/pull/64 [![Coverage Status](https://coveralls.io/builds/10430718/badge)](https://coveralls.io/builds/10430718) Changes Unknown when pulling **67cbdc35e908c888976b0e4464ef87cedef88104 on Jaskey:ROCKETMQ-102-shutdown-await** into ** on apache:master**. > When shutdown(), the persisted offet is not the latest consumed message, > which may cause repeated messages > ---------------------------------------------------------------------------------------------------------- > > 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)