(pulsar) branch master updated: [fix][test] Fix flaky PersistentTopicTerminateTest.testRecoverAfterTerminate (#25345)

[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 ff9f1b90d25 [fix][test] Fix flaky 
PersistentTopicTerminateTest.testRecoverAfterTerminate (#25345)
ff9f1b90d25 is described below

commit ff9f1b90d25fc15a2b3090862984211943aeb0de
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Wed Mar 18 05:54:32 2026 -0700

    [fix][test] Fix flaky 
PersistentTopicTerminateTest.testRecoverAfterTerminate (#25345)
---
 .../org/apache/pulsar/client/api/PersistentTopicTerminateTest.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PersistentTopicTerminateTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PersistentTopicTerminateTest.java
index 4cd9371cd9d..8e39660369b 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PersistentTopicTerminateTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PersistentTopicTerminateTest.java
@@ -64,8 +64,8 @@ public class PersistentTopicTerminateTest extends 
SharedPulsarBaseTest {
         assertEquals(msg2.getValue(), "2");
 
         // Verify: the ledgers acked will be cleaned up.
-        admin.topics().skipAllMessages(topicName, subscriptionName);
-        Awaitility.await().untilAsserted(() -> {
+        consumer.acknowledgeCumulative(msg2);
+        Awaitility.await().atMost(30, TimeUnit.SECONDS).untilAsserted(() -> {
             PersistentTopic persistentTopic =
                     (PersistentTopic) getTopic(topicName, false).join().get();
             ManagedLedgerImpl ml = (ManagedLedgerImpl) 
persistentTopic.getManagedLedger();