This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new d72dc04549b [improve][broker] Change the log level from error to info
when throwing NotAllowedException (#25130)
d72dc04549b is described below
commit d72dc04549b29d5ca73bf742aa81efa74ea107c4
Author: Jiwei Guo <[email protected]>
AuthorDate: Thu Jan 8 11:28:26 2026 +0800
[improve][broker] Change the log level from error to info when throwing
NotAllowedException (#25130)
---
.../org/apache/pulsar/broker/service/persistent/PersistentTopic.java | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
index ae1177d295e..451471e215e 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -1089,6 +1089,9 @@ public class PersistentTopic extends AbstractTopic
implements Topic, AddEntryCal
close();
} else if (ex.getCause() instanceof
BrokerServiceException.ConnectionClosedException) {
log.warn("[{}][{}] Connection was closed while the opening
the cursor", topic, subscriptionName);
+ } else if (ex.getCause() instanceof
BrokerServiceException.NotAllowedException) {
+ log.info("[{}][{}] Not allowed to create subscription:
{}", topic, subscriptionName,
+ ex.getCause().getMessage());
} else {
log.error("[{}] Failed to create subscription: {}", topic,
subscriptionName, ex);
}