(pulsar) branch master updated: [fix][test] Fix flaky UnloadSubscriptionTest.testMultiConsumer (#23243)

[lhotari]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new a678e974e0f [fix][test] Fix flaky 
UnloadSubscriptionTest.testMultiConsumer (#23243)
a678e974e0f is described below

commit a678e974e0f0a615cb774fb2a89b9a45a6c2bc1e
Author: hanmz <gunn...@tencent.com>
AuthorDate: Tue Sep 3 01:12:14 2024 +0800

    [fix][test] Fix flaky UnloadSubscriptionTest.testMultiConsumer (#23243)
---
 .../test/java/org/apache/pulsar/client/api/UnloadSubscriptionTest.java  | 2 ++
 1 file changed, 2 insertions(+)

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
index 93d5bf30ec6..22f7a5d6a43 100644
--- 
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 @@ public class UnloadSubscriptionTest extends 
ProducerConsumerBase {
         super.doInitConf();
         conf.setSystemTopicEnabled(false);
         conf.setTransactionCoordinatorEnabled(false);
+        conf.setAcknowledgmentAtBatchIndexLevelEnabled(true);
     }
 
     @AfterClass(alwaysRun = true)
@@ -242,6 +243,7 @@ public class UnloadSubscriptionTest extends 
ProducerConsumerBase {
                 .subscriptionName(subName)
                 .subscriptionType(subType)
                 .isAckReceiptEnabled(true)
+                .enableBatchIndexAcknowledgment(true)
                 .subscribe();
         return consumer;
     }