From 52b2dd6a5e4ebba1223b704a8283b4b405681eab Mon Sep 17 00:00:00 2001
From: Hankunming <1109939087@qq.com>
Date: Fri, 29 Nov 2024 13:06:10 +0800
Subject: [PATCH] fix: reset offset

---
 src/MQClientFactory.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/MQClientFactory.cpp b/src/MQClientFactory.cpp
index 69d25437e..8225d2e44 100644
--- a/src/MQClientFactory.cpp
+++ b/src/MQClientFactory.cpp
@@ -1167,7 +1167,7 @@ void MQClientFactory::resetOffset(const string& group,
     for (it = offsetTable.begin(); it != offsetTable.end(); ++it) {
       MQMessageQueue mq = it->first;
       if (topic == mq.getTopic()) {
-        pConsumer->removeConsumeOffset(mq);
+        pConsumer->getRebalance()->removePullRequest(mq);
       }
     }