[fix][test] Fix SimpleProducerConsumerTest.testMultiTopicsConsumerImplPauseForManualSubscription (#23546)

NoNPC0532 · lhotari · commit b5c1c1c21691 · 2024-11-13T11:38:04.000+02:00
(cherry picked from commit c4ee362)
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"))

Original file line number	Diff line number	Diff line change
`@@ -3495,7 +3495,7 @@ public void testMultiTopicsConsumerImplPauseForManualSubscription() throws Excep`
`3495`	`3495`	`producer3.send(message.getBytes(UTF_8));`
`3496`	`3496`	`}`
`3497`	`3497`
`3498`		`- int receiverQueueSize = 1;`
	`3498`	`+ int receiverQueueSize = 6;`
`3499`	`3499`	`Consumer<byte[]> consumer = pulsarClient`
`3500`	`3500`	`.newConsumer()`
`3501`	`3501`	`.topics(Lists.newArrayList(topicNameBase + "1", topicNameBase + "2"))`