From 294079c8b6e6ee7db0403d05dcf884f32deb37cc Mon Sep 17 00:00:00 2001
From: Wenzhi Feng <52550727+thetumbled@users.noreply.github.com>
Date: Wed, 20 Nov 2024 16:40:01 +0800
Subject: [PATCH] Update
 pulsar-broker/src/test/java/org/apache/pulsar/client/impl/NegativeAcksTest.java

Co-authored-by: Zixuan Liu <nodeces@gmail.com>
---
 .../java/org/apache/pulsar/client/impl/NegativeAcksTest.java   | 3 +++
 1 file changed, 3 insertions(+)

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
index 71590a95d8e74..f8bc30f09667c 100644
--- 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");