[improve][broker] Change topic exists log to warn (apache#24116)

shibd · srinath-ctds · commit 71330c42f6a4 · 2025-03-31T12:55:27.000+05:30
(cherry picked from commit 9ea171d) (cherry picked from commit 1832fe4)
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
@@ -341,7 +341,7 @@ protected CompletableFuture<Void> internalCreateNonPartitionedTopicAsync(boolean
            .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);

Original file line number	Diff line number	Diff line change
`@@ -341,7 +341,7 @@ protected CompletableFuture<Void> internalCreateNonPartitionedTopicAsync(boolean`
`341`	`341`	`.thenCompose(__ -> pulsar().getBrokerService().getTopicIfExists(topicName.toString()))`
`342`	`342`	`.thenCompose(existedTopic -> {`
`343`	`343`	`if (existedTopic.isPresent()) {`
`344`		`- log.error("[{}] Topic {} already exists", clientAppId(), topicName);`
	`344`	`+ log.warn("[{}] Topic {} already exists", clientAppId(), topicName);`
`345`	`345`	`throw new RestException(Status.CONFLICT, "This topic already exists");`
`346`	`346`	`}`
`347`	`347`	`return pulsar().getBrokerService().getTopic(topicName.toString(), true, properties);`