diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java index 097cf4823de26..9b1848c9ff3a4 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java @@ -698,6 +698,7 @@ public void testActiveAndInActiveConsumerEntryCacheBehavior() throws Exception { .topic("persistent://my-property/use/my-ns/" + topicName) .subscriptionName(sub2) .subscriptionType(SubscriptionType.Shared) + .receiverQueueSize(1) .subscribe(); // Produce messages final int moreMessages = 10;