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;
                     }