You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ba...@apache.org on 2025/03/25 07:27:00 UTC
(pulsar) branch branch-4.0 updated: [improve][broker] Change topic exists log to warn (#24116)
This is an automated email from the ASF dual-hosted git repository.
baodi pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new 1832fe4b8a8 [improve][broker] Change topic exists log to warn (#24116)
1832fe4b8a8 is described below
commit 1832fe4b8a83f43998e3fe6f41d67f1cf6455876
Author: Baodi Shi <ba...@apache.org>
AuthorDate: Tue Mar 25 15:23:23 2025 +0800
[improve][broker] Change topic exists log to warn (#24116)
(cherry picked from commit 9ea171d937df806a29d0ede633b1ccbbc78ea3f3)
---
.../java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
index ed47650f42a..d24011c6422 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
@@ -341,7 +341,7 @@ public class PersistentTopicsBase extends AdminResource {
.thenCompose(__ -> pulsar().getBrokerService().getTopicIfExists(topicName.toString()))
.thenCompose(existedTopic -> {
if (existedTopic.isPresent()) {
- log.error("[{}] Topic {} already exists", clientAppId(), topicName);
+ log.warn("[{}] Topic {} already exists", clientAppId(), topicName);
throw new RestException(Status.CONFLICT, "This topic already exists");
}
return pulsar().getBrokerService().getTopic(topicName.toString(), true, properties);