diff --git a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/NamespaceResources.java b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/NamespaceResources.java index f80427fb84bf3..34b42ecc4eabf 100644 --- a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/NamespaceResources.java +++ b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/NamespaceResources.java @@ -153,13 +153,16 @@ public CompletableFuture setPoliciesAsync(NamespaceName ns, Function persistentTopicExists(TopicName topic) { } public CompletableFuture clearNamespacePersistence(NamespaceName ns) { - String path = MANAGED_LEDGER_PATH + "/" + ns; - log.info().attr("namespace", ns).attr("path", path).log("Clearing namespace persistence for namespace: , path"); - return store.deleteIfExists(path, Optional.empty()); + return clearManagedLedgerPathIfExistsAsync(ns, MANAGED_LEDGER_PATH + "/" + ns, + "Clearing namespace persistence for namespace: , path"); } public CompletableFuture clearDomainPersistence(NamespaceName ns) { - String path = MANAGED_LEDGER_PATH + "/" + ns + "/persistent"; - log.info().attr("namespace", ns).attr("path", path).log("Clearing domain persistence for namespace: , path"); + return clearManagedLedgerPathIfExistsAsync(ns, MANAGED_LEDGER_PATH + "/" + ns + "/persistent", + "Clearing domain persistence for namespace: , path"); + } + + private CompletableFuture clearManagedLedgerPathIfExistsAsync( + NamespaceName ns, String path, String logMessage) { + log.info().attr("namespace", ns).attr("path", path).log(logMessage); return store.deleteIfExists(path, Optional.empty()); }