ShannonDing opened a new issue, #4584:
URL: https://github.com/apache/rocketmq/issues/4584
**BUG REPORT**
1. Please describe the issue you observed
- update Consume Offset after pull message from remote queue. **the
messagequeue is warped by namespace**
```
@Override
public void updateConsumeOffset(MessageQueue mq, long offset) throws
MQClientException {
this.defaultMQPullConsumerImpl.updateConsumeOffset(queueWithNamespace(mq),
offset);
}
```
- get offset store
```
@Deprecated
public OffsetStore getOffsetStore() {
return offsetStore;
}
```
- persist offset table manually
```
@Override
public void persist(MessageQueue mq) {
AtomicLong offset = this.offsetTable.get(mq);
if (offset != null) {
try {
this.updateConsumeOffsetToBroker(mq, offset.get());
log.info("[persist] Group: {} ClientId: {}
updateConsumeOffsetToBroker {} {}",
this.groupName,
this.mQClientFactory.getClientId(),
mq,
offset.get());
} catch (Exception e) {
log.error("updateConsumeOffsetToBroker exception, " +
mq.toString(), e);
}
}
}
```
the offset will not update to broker as the offset can not be found in the
offsettable.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
