(pulsar) branch master updated: [fix][test] Fix DeadLetterTopicTest.testDeadLetterTopicWithInitialSubscriptionAndMultiConsumers (#23552)

[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 c266db236df [fix][test] Fix 
DeadLetterTopicTest.testDeadLetterTopicWithInitialSubscriptionAndMultiConsumers 
(#23552)
c266db236df is described below

commit c266db236df5f57bf59df1b25a23521419b2ad02
Author: CrazyCoder <18235787...@163.com>
AuthorDate: Wed Nov 6 20:56:57 2024 +0800

    [fix][test] Fix 
DeadLetterTopicTest.testDeadLetterTopicWithInitialSubscriptionAndMultiConsumers 
(#23552)
---
 .../test/java/org/apache/pulsar/client/api/DeadLetterTopicTest.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/DeadLetterTopicTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/DeadLetterTopicTest.java
index f5a74dcd166..7d34ce33e0a 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/DeadLetterTopicTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/DeadLetterTopicTest.java
@@ -1010,7 +1010,7 @@ public class DeadLetterTopicTest extends 
ProducerConsumerBase {
                         .maxRedeliverCount(maxRedeliveryCount)
                         .initialSubscriptionName(dlqInitialSub)
                         .build())
-                .receiverQueueSize(100)
+                .receiverQueueSize(20)
                 
.subscriptionInitialPosition(SubscriptionInitialPosition.Earliest)
                 .subscribe();
 
@@ -1023,7 +1023,7 @@ public class DeadLetterTopicTest extends 
ProducerConsumerBase {
                         .maxRedeliverCount(maxRedeliveryCount)
                         .initialSubscriptionName(dlqInitialSub)
                         .build())
-                .receiverQueueSize(100)
+                .receiverQueueSize(20)
                 
.subscriptionInitialPosition(SubscriptionInitialPosition.Earliest)
                 .subscribe();