This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-4.1 by this push:
     new 77acdc60ae0 [improve][broker] Change the log level from error to info 
when throwing NotAllowedException (#25130)
77acdc60ae0 is described below

commit 77acdc60ae07a3918117ffc17e3d86007aa3834a
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 22f3be27d58..73a773dd741 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);
                 }

Reply via email to