[ 
https://issues.apache.org/jira/browse/ROCKETMQ-112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

yukon closed ROCKETMQ-112.
--------------------------
    Resolution: Won't Fix

> MQ client CONSUME_FROM_LAST_OFFSET dont work
> --------------------------------------------
>
>                 Key: ROCKETMQ-112
>                 URL: https://issues.apache.org/jira/browse/ROCKETMQ-112
>             Project: Apache RocketMQ
>          Issue Type: Bug
>          Components: rocketmq-client
>            Reporter: zhaoziyan
>            Assignee: Xiaorui Wang
>
>         case CONSUME_FROM_LAST_OFFSET: {
>             long lastOffset = offsetStore.readOffset(mq, 
> ReadOffsetType.READ_FROM_STORE);
>             if (lastOffset >= 0) {
>                 result = lastOffset;
>             }
>             // First start,no offset
>             else if (-1 == lastOffset) {
>                 if 
> (mq.getTopic().startsWith(MixAll.RETRY_GROUP_TOPIC_PREFIX)) {
>                     result = 0L;
>                 }
>                 else {
>                     try {
>                         result = 
> this.mQClientFactory.getMQAdminImpl().maxOffset(mq);
>                     }
>                     catch (MQClientException e) {
>                         result = -1;
>                     }
>                 }
>             }
>             else {
>                 result = -1;
>             }
>             break;
>         }
> offsetStore.readOffset is minOffset not the maxOffset 
> CONSUME_FROM_LAST_OFFSET dont work



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

Reply via email to