Update pulsar-broker/src/test/java/org/apache/pulsar/client/impl/Nega…

…tiveAcksTest.java Co-authored-by: Zixuan Liu <[email protected]>
thetumbled · Nov 20, 2024 · 294079c · 294079c
1 parent 0ee1a54
commit 294079c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/NegativeAcksTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/NegativeAcksTest.java
@@ -350,6 +350,9 @@ public void testNegativeAcksWithBatch() throws Exception {
         @Cleanup
         Producer<String> producer = pulsarClient.newProducer(Schema.STRING)
                 .topic(topic)
+                .enableBatching(true)
+                .batchingMaxPublishDelay(1, TimeUnit.HOURS)
+                .batchingMaxMessages(2)
                 .create();
         // send two messages in the same batch
         producer.sendAsync("test-0");