From 199cc15bf2dcc7b7ed62e68606e24cbea24a7e13 Mon Sep 17 00:00:00 2001 From: Chai-YD <1030333788@qq.com> Date: Thu, 28 Mar 2024 16:08:28 +0800 Subject: [PATCH] =?UTF-8?q?Update=20DefaultMQPullConsumer.cpp=EF=BC=8Csupp?= =?UTF-8?q?ort=20persistConsumerOffset4PullConsumer?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/consumer/DefaultMQPullConsumer.cpp | 1 + 1 file changed, 1 insertion(+) 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); } //