[fix][test] Fix flaky UnloadSubscriptionTest.testMultiConsumer (#23243)

(cherry picked from commit a678e97)
apache · Sep 5, 2024 · 3935276 · 3935276
1 parent f9283da
commit 3935276
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/UnloadSubscriptionTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/UnloadSubscriptionTest.java
@@ -60,6 +60,7 @@ protected void doInitConf() throws Exception {
         super.doInitConf();
         conf.setSystemTopicEnabled(false);
         conf.setTransactionCoordinatorEnabled(false);
+        conf.setAcknowledgmentAtBatchIndexLevelEnabled(true);
     }
 
     @AfterClass(alwaysRun = true)
@@ -242,6 +243,7 @@ private Consumer<String> createConsumer(String topicName, String subName, Subscr
                 .subscriptionName(subName)
                 .subscriptionType(subType)
                 .isAckReceiptEnabled(true)
+                .enableBatchIndexAcknowledgment(true)
                 .subscribe();
         return consumer;
     }