Set log level to warn when topic policy reader occurs AlreadyClosed…

…Exception. (apache#17841)
nahguam · Sep 26, 2022 · e092064 · e092064
1 parent 7f96547
commit e092064
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java b/.../src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java
@@ -395,7 +395,7 @@ private void readMorePolicies(SystemTopicClient.Reader<PulsarEvent> reader) {
                   } else {
                       Throwable cause = FutureUtil.unwrapCompletionException(ex);
                       if (cause instanceof PulsarClientException.AlreadyClosedException) {
-                          log.error("Read more topic policies exception, close the read now!", ex);
+                          log.warn("Read more topic policies exception, close the read now!", ex);
                           cleanCacheAndCloseReader(
                                   reader.getSystemTopic().getTopicName().getNamespaceObject(), false);
                       } else {