(pulsar) branch master updated: [fix][test] Fix flaky AdminApiTest.persistentTopicsCursorResetAfterReset timeout (#25692)

[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 64e0e0f1599 [fix][test] Fix flaky 
AdminApiTest.persistentTopicsCursorResetAfterReset timeout (#25692)
64e0e0f1599 is described below

commit 64e0e0f15992323df0405d215a18739c38b8f7d1
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Wed May 6 05:54:10 2026 -0700

    [fix][test] Fix flaky AdminApiTest.persistentTopicsCursorResetAfterReset 
timeout (#25692)
---
 .../java/org/apache/pulsar/broker/admin/AdminApiTest.java     | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

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 f01eb69ea4b..60375f9d335 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
@@ -2932,7 +2932,8 @@ public class AdminApiTest extends 
MockedPulsarServiceBaseTest {
         });
 
         for (int i = 0; i < 10; i++) {
-            Message<byte[]> message = consumer.receive();
+            Message<byte[]> message = consumer.receive(30, TimeUnit.SECONDS);
+            assertNotNull(message, "Failed to receive initial message-" + i);
             consumer.acknowledge(message);
         }
 
@@ -2942,7 +2943,9 @@ public class AdminApiTest extends 
MockedPulsarServiceBaseTest {
 
         // Should received messages from 5-9
         for (int i = 5; i < 10; i++) {
-            Message<byte[]> message = consumer.receive();
+            Message<byte[]> message = consumer.receive(30, TimeUnit.SECONDS);
+            assertNotNull(message,
+                    "Failed to receive message-" + i + " after first 
resetCursor (firstTimestamp)");
             consumer.acknowledge(message);
             ++receivedAfterReset;
             String expected = "message-" + i;
@@ -2956,7 +2959,9 @@ public class AdminApiTest extends 
MockedPulsarServiceBaseTest {
 
         // Should received messages from 8-9
         for (int i = 8; i < 10; i++) {
-            Message<byte[]> message = consumer.receive();
+            Message<byte[]> message = consumer.receive(30, TimeUnit.SECONDS);
+            assertNotNull(message,
+                    "Failed to receive message-" + i + " after second 
resetCursor (secondTimestamp)");
             consumer.acknowledge(message);
             ++receivedAfterReset;
             String expected = "message-" + i;