This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.3 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 1bb1cf1bc0363c06a80f8189c4ec4bb95a00782c Author: CrazyCoder <[email protected]> AuthorDate: Wed Nov 6 11:24:08 2024 +0800 [fix][test] Fix SimpleProducerConsumerTest.testMultiTopicsConsumerImplPauseForManualSubscription (#23546) (cherry picked from commit c4ee362f7e97b91549b7b13224315fe758b6e1b6) --- .../java/org/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 d37bd484bfb..3edf2dd42aa 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 class SimpleProducerConsumerTest extends ProducerConsumerBase { producer3.send(message.getBytes(UTF_8)); } - int receiverQueueSize = 1; + int receiverQueueSize = 6; Consumer<byte[]> consumer = pulsarClient .newConsumer() .topics(Lists.newArrayList(topicNameBase + "1", topicNameBase + "2"))
