[fix][test] Wait for txn.abort() to complete to avoid AdminApiTransactionTest.testAnalyzeSubscriptionBacklogWithTransactionMarker() flaky test (apache#25125)

oneby-wang · srinath-ctds · commit 9c474644d21a · 2026-01-20T22:05:05.000+05:30
(cherry picked from commit 40953cb) (cherry picked from commit aca3cf0)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v3/AdminApiTransactionTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v3/AdminApiTransactionTest.java
@@ -1092,7 +1092,7 @@ public void testAnalyzeSubscriptionBacklogWithTransactionMarker() throws Excepti
             Transaction txn = pulsarClient.newTransaction().build().get();
             MessageId messageId = producer.newMessage(txn).value("aborted-msg" + i).send();
             abortedMsgIds.add(messageId);
-            txn.abort();
+            txn.abort().get();
         }
         backlogResult = admin.topics().analyzeSubscriptionBacklog(topic, transactionSubName, Optional.empty());
         assertEquals(backlogResult.getMessages(), numMessages * 2);

Original file line number	Diff line number	Diff line change
`@@ -1092,7 +1092,7 @@ public void testAnalyzeSubscriptionBacklogWithTransactionMarker() throws Excepti`
`1092`	`1092`	`Transaction txn = pulsarClient.newTransaction().build().get();`
`1093`	`1093`	`MessageId messageId = producer.newMessage(txn).value("aborted-msg" + i).send();`
`1094`	`1094`	`abortedMsgIds.add(messageId);`
`1095`		`- txn.abort();`
	`1095`	`+ txn.abort().get();`
`1096`	`1096`	`}`
`1097`	`1097`	`backlogResult = admin.topics().analyzeSubscriptionBacklog(topic, transactionSubName, Optional.empty());`
`1098`	`1098`	`assertEquals(backlogResult.getMessages(), numMessages * 2);`