diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerBatchReceiveTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerBatchReceiveTest.java index 5857221fbe114..bb2faecffb4c0 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerBatchReceiveTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerBatchReceiveTest.java @@ -170,6 +170,22 @@ public Object[][] batchReceivePolicyProvider() { .maxNumBytes(-100) .timeout(50, TimeUnit.MILLISECONDS) .build(), false, 30 + }, + // Only timeout present + { + BatchReceivePolicy.builder() + .maxNumMessages(0) + .maxNumBytes(0) + .timeout(50, TimeUnit.MILLISECONDS) + .build(), false, 30 + }, + // Only timeout present + { + BatchReceivePolicy.builder() + .maxNumMessages(-1) + .maxNumBytes(-1) + .timeout(50, TimeUnit.MILLISECONDS) + .build(), false, 30 } }; }