added retry in topic deletion

prestodb · Dec 18, 2024 · 203cbe8 · 203cbe8
1 parent f364578
commit 203cbe8
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/tempto-kafka/src/main/java/io/prestodb/tempto/fulfillment/table/kafka/KafkaTableManager.java b/tempto-kafka/src/main/java/io/prestodb/tempto/fulfillment/table/kafka/KafkaTableManager.java
@@ -124,6 +124,12 @@ private void deleteTopic(String topic) {
                 }
                 DeleteTopicsResult deleteTopicsResult = adminClient.deleteTopics(Collections.singletonList(topic));
                 deleteTopicsResult.all().get();
+                try {
+                    Thread.sleep(1_000); // Wait for metadata propagation
+                } catch (InterruptedException e) {
+                    Thread.currentThread().interrupt();
+                    throw new RuntimeException("Interrupted while waiting for topic deletion: " + topic, e);
+                }
             } catch (ExecutionException | InterruptedException e) {
                 throw new RuntimeException("Failed to delete topic " + topic, e);
             }