From 1eebb81dbf8a6a54c7d9b25aa7bce2dcd428713c Mon Sep 17 00:00:00 2001 From: CrazyCoder <18235787078@163.com> Date: Wed, 6 Nov 2024 20:56:57 +0800 Subject: [PATCH] [fix][test] Fix DeadLetterTopicTest.testDeadLetterTopicWithInitialSubscriptionAndMultiConsumers (#23552) (cherry picked from commit c266db236df5f57bf59df1b25a23521419b2ad02) --- .../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 f5a74dcd1661b..7d34ce33e0a7f 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 void testDeadLetterTopicWithInitialSubscriptionAndMultiConsumers() throws .maxRedeliverCount(maxRedeliveryCount) .initialSubscriptionName(dlqInitialSub) .build()) - .receiverQueueSize(100) + .receiverQueueSize(20) .subscriptionInitialPosition(SubscriptionInitialPosition.Earliest) .subscribe(); @@ -1023,7 +1023,7 @@ public void testDeadLetterTopicWithInitialSubscriptionAndMultiConsumers() throws .maxRedeliverCount(maxRedeliveryCount) .initialSubscriptionName(dlqInitialSub) .build()) - .receiverQueueSize(100) + .receiverQueueSize(20) .subscriptionInitialPosition(SubscriptionInitialPosition.Earliest) .subscribe();