From b5c1c1c2169133ea75a623b0c9d34e0f6f6875b6 Mon Sep 17 00:00:00 2001
From: CrazyCoder <18235787078@163.com>
Date: Wed, 6 Nov 2024 11:24:08 +0800
Subject: [PATCH] [fix][test] Fix
 SimpleProducerConsumerTest.testMultiTopicsConsumerImplPauseForManualSubscription
 (#23546)

(cherry picked from commit c4ee362f7e97b91549b7b13224315fe758b6e1b6)
---
 .../apache/pulsar/client/api/SimpleProducerConsumerTest.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
index 7877d5ab604c5..d8e981220f89e 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
@@ -3495,7 +3495,7 @@ public void testMultiTopicsConsumerImplPauseForManualSubscription() throws Excep
             producer3.send(message.getBytes(UTF_8));
         }
 
-        int receiverQueueSize = 1;
+        int receiverQueueSize = 6;
         Consumer<byte[]> consumer = pulsarClient
             .newConsumer()
             .topics(Lists.newArrayList(topicNameBase + "1", topicNameBase + "2"))