[GitHub] [rocketmq] ShannonDing opened a new issue, #4584: lack of namespace when update consumer offset by persist api in DefaultPullConsumer.

[GitBox <gi...@apache.org>]

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: dev-unsubscribe@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq] ShannonDing closed issue #4584: lack of namespace when update consumer offset by persist api in DefaultPullConsumer.

[GitBox <gi...@apache.org>]

ShannonDing closed issue #4584: lack of namespace when update consumer offset by persist api in DefaultPullConsumer.
URL: https://github.com/apache/rocketmq/issues/4584


-- 
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: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org