[fix][test] Fix SimpleProducerConsumerTest.testMultiTopicsConsumerImp…

…lPauseForManualSubscription (apache#23546) (cherry picked from commit c4ee362) (cherry picked from commit b5c1c1c)
datastax · Nov 21, 2024 · fcae9fc · fcae9fc
1 parent 97d5d9c
commit fcae9fc
Showing 1 changed file with 1 addition and 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
@@ -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"))