diff --git a/src/consumer/DefaultMQPullConsumer.cpp b/src/consumer/DefaultMQPullConsumer.cpp
index a5ccfc49a..913e3d76e 100644
--- a/src/consumer/DefaultMQPullConsumer.cpp
+++ b/src/consumer/DefaultMQPullConsumer.cpp
@@ -192,6 +192,7 @@ void DefaultMQPullConsumer::fetchMessageQueuesInBalance(const std::string& topic
 }
 void DefaultMQPullConsumer::persistConsumerOffset4PullConsumer(const MQMessageQueue& mq) {
   // impl->persistConsumerOffsetByResetOffset(mq);
+  impl->persistConsumerOffset4PullConsumer(mq);
 }
 
 //<!************************************************************************