zhaoziyan created ROCKETMQ-112:
----------------------------------
Summary: 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)
