Use info level log for not found or conflict errors

apache · Feb 6, 2025 · 2b702dd · 2b702dd
1 parent 6d6b4fe
commit 2b702dd
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java
@@ -625,7 +625,7 @@ && pulsar().getConfig().isCreateTopicToRemoteClusterForReplication()) {
                 })
                 .exceptionally(ex -> {
                     if (AdminResource.isConflictException(ex)) {
-                        log.warn("[{}] Failed to create partitioned topic {}: {}", clientAppId(), topicName,
+                        log.info("[{}] Failed to create partitioned topic {}: {}", clientAppId(), topicName,
                                 ex.getMessage());
                     } else {
                         log.error("[{}] Failed to create partitioned topic {}", clientAppId(), topicName, ex);

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
@@ -156,7 +156,7 @@ public void getPolicies(@Suspended AsyncResponse response,
                 .thenAccept(response::resume)
                 .exceptionally(ex -> {
                     if (AdminResource.isNotFoundOrConflictException(ex)) {
-                        log.warn("Failed to get policies for namespace {}: {}", namespaceName, ex.getMessage());
+                        log.info("Failed to get policies for namespace {}: {}", namespaceName, ex.getMessage());
                     } else {
                         log.error("Failed to get policies for namespace {}", namespaceName, ex);
                     }

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
@@ -946,7 +946,7 @@ public void getPartitionedMetadata(
                     Throwable t = FutureUtil.unwrapCompletionException(ex);
                     if (!isRedirectException(t)) {
                         if (AdminResource.isNotFoundException(t)) {
-                            log.warn("[{}] Failed to get partitioned metadata topic {}: {}",
+                            log.info("[{}] Failed to get partitioned metadata topic {}: {}",
                                     clientAppId(), topicName, ex.getMessage());
                         } else {
                             log.error("[{}] Failed to get partitioned metadata topic {}",