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

oneby-wang · lhotari · commit d558b929a23f · 2026-01-08T18:25:52.000+02:00
(cherry picked from commit 40953cb)
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
@@ -1091,7 +1091,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
`@@ -1091,7 +1091,7 @@ public void testAnalyzeSubscriptionBacklogWithTransactionMarker() throws Excepti`
`1091`	`1091`	`Transaction txn = pulsarClient.newTransaction().build().get();`
`1092`	`1092`	`MessageId messageId = producer.newMessage(txn).value("aborted-msg" + i).send();`
`1093`	`1093`	`abortedMsgIds.add(messageId);`
`1094`		`- txn.abort();`
	`1094`	`+ txn.abort().get();`
`1095`	`1095`	`}`
`1096`	`1096`	`backlogResult = admin.topics().analyzeSubscriptionBacklog(topic, transactionSubName, Optional.empty());`
`1097`	`1097`	`assertEquals(backlogResult.getMessages(), numMessages * 2);`