(gravitino) branch branch-1.3 updated: [Cherry-pick to branch-1.3] [#12248] test(catalog-kafka): wait for topic deletion in testNameSpec (#12268) (#12279)

[jshao]

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

jerryshao pushed a commit to branch branch-1.3
in repository https://gitbox.apache.org/repos/asf/gravitino.git


The following commit(s) were added to refs/heads/branch-1.3 by this push:
     new 032f6718e7 [Cherry-pick to branch-1.3] [#12248] test(catalog-kafka): 
wait for topic deletion in testNameSpec (#12268) (#12279)
032f6718e7 is described below

commit 032f6718e773e1df16e823bfec1cd1170453821b
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Jul 31 14:47:27 2026 +0800

    [Cherry-pick to branch-1.3] [#12248] test(catalog-kafka): wait for topic 
deletion in testNameSpec (#12268) (#12279)
    
    **Cherry-pick Information:**
    - Original commit: 72a25d51728c794ed533eecbd0f8bf08b57dba98
    - Target branch: `branch-1.3`
    - Status: ✅ Clean cherry-pick (no conflicts)
    
    Co-authored-by: mchades <liminghu...@datastrato.com>
---
 .../apache/gravitino/catalog/kafka/integration/test/CatalogKafkaIT.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/catalogs/catalog-kafka/src/test/java/org/apache/gravitino/catalog/kafka/integration/test/CatalogKafkaIT.java
 
b/catalogs/catalog-kafka/src/test/java/org/apache/gravitino/catalog/kafka/integration/test/CatalogKafkaIT.java
index cb017ad297..1429e2708b 100644
--- 
a/catalogs/catalog-kafka/src/test/java/org/apache/gravitino/catalog/kafka/integration/test/CatalogKafkaIT.java
+++ 
b/catalogs/catalog-kafka/src/test/java/org/apache/gravitino/catalog/kafka/integration/test/CatalogKafkaIT.java
@@ -450,6 +450,7 @@ public class CatalogKafkaIT extends BaseIT {
         Arrays.stream(topics).anyMatch(topic -> 
topic.name().equals(illegalName)));
 
     Assertions.assertTrue(catalog.asTopicCatalog().dropTopic(ident));
+    awaitTopicDeletedInKafka(illegalName);
     Assertions.assertFalse(catalog.asTopicCatalog().topicExists(ident));
   }