[fix][test] Fix flaky UnloadSubscriptionTest.testMultiConsumer (apach…

…e#23243) (cherry picked from commit a678e97) (cherry picked from commit fe5407d)
datastax · Sep 12, 2024 · 01c5605 · 01c5605
1 parent 8a3bba7
commit 01c5605
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;
     }