(pulsar) branch master updated: [fix][test] Fix SimpleProducerConsumerTest.testMultiTopicsConsumerImplPauseForManualSubscription (#23546)

[technoboy]

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

technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new c4ee362f7e9 [fix][test] Fix 
SimpleProducerConsumerTest.testMultiTopicsConsumerImplPauseForManualSubscription
 (#23546)
c4ee362f7e9 is described below

commit c4ee362f7e97b91549b7b13224315fe758b6e1b6
Author: CrazyCoder <18235787...@163.com>
AuthorDate: Wed Nov 6 11:24:08 2024 +0800

    [fix][test] Fix 
SimpleProducerConsumerTest.testMultiTopicsConsumerImplPauseForManualSubscription
 (#23546)
---
 .../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 a867dc0cd35..e99abac1ec4 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
@@ -3520,7 +3520,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"))