From 9e3dd25681b8c4fa15cb7eacc044b9a9b89df2ca Mon Sep 17 00:00:00 2001 From: Paul Gier Date: Thu, 9 Apr 2026 19:00:17 -0500 Subject: [PATCH 1/2] update error message to include tenant name --- .../org/apache/pulsar/broker/admin/impl/NamespacesBase.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java index 89050fbd288ba..f0c70d009a003 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java @@ -142,7 +142,7 @@ protected CompletableFuture> internalGetTenantNamespaces(String ten .thenCompose(__ -> tenantResources().tenantExistsAsync(tenant)) .thenCompose(existed -> { if (!existed) { - throw new RestException(Status.NOT_FOUND, "Tenant not found"); + throw new RestException(Status.NOT_FOUND, "Tenant not found: " + tenant); } return tenantResources().getListOfNamespacesAsync(tenant); }); From 8e501a97d9ed5c0594491e20d05d972cc72b4bbc Mon Sep 17 00:00:00 2001 From: Paul Gier Date: Fri, 10 Apr 2026 10:06:18 -0500 Subject: [PATCH 2/2] add tenant name to log message only --- .../org/apache/pulsar/broker/admin/impl/NamespacesBase.java | 2 +- .../main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java index f0c70d009a003..89050fbd288ba 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java @@ -142,7 +142,7 @@ protected CompletableFuture> internalGetTenantNamespaces(String ten .thenCompose(__ -> tenantResources().tenantExistsAsync(tenant)) .thenCompose(existed -> { if (!existed) { - throw new RestException(Status.NOT_FOUND, "Tenant not found: " + tenant); + throw new RestException(Status.NOT_FOUND, "Tenant not found"); } return tenantResources().getListOfNamespacesAsync(tenant); }); diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java index b691559cb8b57..e150143c220d5 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java @@ -109,7 +109,7 @@ public void getTenantNamespaces(@Suspended final AsyncResponse response, internalGetTenantNamespaces(tenant) .thenAccept(response::resume) .exceptionally(ex -> { - log.error("[{}] Failed to get namespaces list: {}", clientAppId(), ex); + log.error("[{}] Failed to get namespaces list for tenant {}: {}", clientAppId(), tenant, ex); resumeAsyncResponseExceptionally(response, ex); return null; });