From 214357728172fd0babd7b38935c0ebdad53ac7aa Mon Sep 17 00:00:00 2001
From: mxsm <mxsm@apache.org>
Date: Tue, 26 Aug 2025 22:32:41 +0800
Subject: [PATCH] [ISSUE #9642]Adjust acknowledgment logic to handle one slave
 acknowledgment correctly

---
 .../org/apache/rocketmq/store/ha/GroupTransferService.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/store/src/main/java/org/apache/rocketmq/store/ha/GroupTransferService.java b/store/src/main/java/org/apache/rocketmq/store/ha/GroupTransferService.java
index a75cae8ef0c..3da34072236 100644
--- a/store/src/main/java/org/apache/rocketmq/store/ha/GroupTransferService.java
+++ b/store/src/main/java/org/apache/rocketmq/store/ha/GroupTransferService.java
@@ -89,7 +89,8 @@ private void doWaitTransfer() {
                         this.notifyTransferObject.waitForRunning(1);
                     }
 
-                    if (!allAckInSyncStateSet && req.getAckNums() <= 1) {
+                    //handle only one slave ack, ackNums <= 2 means master + 1 slave
+                    if (!allAckInSyncStateSet && req.getAckNums() <= 2) {
                         transferOK = haService.getPush2SlaveMaxOffset().get() >= req.getNextOffset();
                         continue;
                     }