(pulsar) 01/04: [fix][test] Fix flaky BatchMessageWithBatchIndexLevelTest.testBatchMessageAck (#24212)

[lhotari]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit 18b265c2184f963c4ba965d9f6e5f9fcaf38655e
Author: Zixuan Liu <node...@gmail.com>
AuthorDate: Sat Apr 26 16:12:25 2025 +0800

    [fix][test] Fix flaky 
BatchMessageWithBatchIndexLevelTest.testBatchMessageAck (#24212)
    
    Signed-off-by: Zixuan Liu <node...@gmail.com>
    (cherry picked from commit 94c7a407a174215535abb34af03de1b1dc384ca1)
---
 .../pulsar/broker/service/BatchMessageWithBatchIndexLevelTest.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BatchMessageWithBatchIndexLevelTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BatchMessageWithBatchIndexLevelTest.java
index f21ac130e3c..f58c16ce092 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BatchMessageWithBatchIndexLevelTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BatchMessageWithBatchIndexLevelTest.java
@@ -85,7 +85,7 @@ public class BatchMessageWithBatchIndexLevelTest extends 
BatchMessageTest {
                 .newConsumer()
                 .topic(topicName)
                 .subscriptionName(subscriptionName)
-                .receiverQueueSize(50)
+                .receiverQueueSize(numMsgs)
                 .subscriptionType(SubscriptionType.Shared)
                 .enableBatchIndexAcknowledgment(true)
                 .negativeAckRedeliveryDelay(100, TimeUnit.MILLISECONDS)