diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerBatchReceiveTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerBatchReceiveTest.java
index 4d5aa121fda0f..09d4976c1a2d2 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerBatchReceiveTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerBatchReceiveTest.java
@@ -629,10 +629,11 @@ private void batchReceiveAndRedelivery(Consumer<String> consumer, int expected)
                     Assert.assertNotNull(message.getValue());
                     log.info("Get message {} from batch", message.getValue());
                 }
+                consumer.acknowledge(messages);
             }
-            consumer.acknowledge(messages);
         } while (messageReceived < expected * 2);
-        Assert.assertEquals(expected * 2, messageReceived);
+        Assert.assertTrue(messageReceived >= expected * 2,
+                "Expected at least " + (expected * 2) + " messages but received " + messageReceived);
     }