import com.alibaba.rocketmq.client.consumer.store.OffsetStore; //导入依赖的package包/类
/**
 * 测试尝试更新offerset
 */
@Test
public void testModify() {
    try {
        long l = consumer.fetchConsumeOffset(mq, false);
        System.out.println("得到offerset" + l);
        //更新offerset
        consumer.updateConsumeOffset(mq, l + 1);
        OffsetStore offsetStore = consumer.getDefaultMQPullConsumerImpl().getOffsetStore();
        offsetStore.persist(mq);
        l = consumer.fetchConsumeOffset(mq, false);
        System.out.println("更新后的offerset" + l);

    } catch (MQClientException e) {
        e.printStackTrace();
    }
}
 

import com.alibaba.rocketmq.client.consumer.store.OffsetStore; //导入依赖的package包/类
public OffsetStore getOffsetStore() {
    return offsetStore;
}
 

import com.alibaba.rocketmq.client.consumer.store.OffsetStore; //导入依赖的package包/类
public void setOffsetStore(OffsetStore offsetStore) {
    this.offsetStore = offsetStore;
}
 

import com.alibaba.rocketmq.client.consumer.store.OffsetStore; //导入依赖的package包/类
/**
 * 更新offerset
 *
 * @param offerSet    更新值
 * @param offsetStore offsetStore
 * @param mq          需要更新的队列
 * @throws MQClientException
 */
public void saveOfferSet(long offerSet, OffsetStore offsetStore, MessageQueue mq) throws MQClientException {
    System.out.println("当前offerset" + offerSet);
    consumer.updateConsumeOffset(mq, offerSet);
    offsetStore.persist(mq);
}