(pulsar) branch master updated: [fix][test] Fix flaky AdminApiTest.partitionedTopicsCursorReset (#25847)

[zixuan]

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

nodece 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 8d2c2e40fbc [fix][test] Fix flaky 
AdminApiTest.partitionedTopicsCursorReset (#25847)
8d2c2e40fbc is described below

commit 8d2c2e40fbce2ad4e22d4329415abdafe175723d
Author: Lari Hotari <lhot...@users.noreply.github.com>
AuthorDate: Thu May 21 05:10:28 2026 +0300

    [fix][test] Fix flaky AdminApiTest.partitionedTopicsCursorReset (#25847)
---
 .../test/java/org/apache/pulsar/broker/admin/AdminApiTest.java    | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java
index 60375f9d335..ce966b707aa 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java
@@ -3101,7 +3101,13 @@ public class AdminApiTest extends 
MockedPulsarServiceBaseTest {
         assertEquals(receivedMessages.size(), 0);
 
         consumer.close();
-        admin.topics().deleteSubscription(topicName, "my-sub");
+        // consumer.close() returns when the close request is dispatched, but 
the broker may not
+        // have processed the disconnect yet, so deleteSubscription can still 
see active consumers
+        // and return HTTP 412. Retry until the broker has detected the 
disconnect.
+        final String topicNameFinal = topicName;
+        Awaitility.await()
+                
.ignoreExceptionsInstanceOf(PulsarAdminException.PreconditionFailedException.class)
+                .untilAsserted(() -> 
admin.topics().deleteSubscription(topicNameFinal, "my-sub"));
         admin.topics().deletePartitionedTopic(topicName);
     }