From 55deee70a70979a2c08c2201d1118496c2f1f183 Mon Sep 17 00:00:00 2001
From: coderzc <zhaocong@apache.org>
Date: Tue, 9 Dec 2025 16:00:47 +0800
Subject: [PATCH] [improve][broker] Enhance logging for subscription creation
 failures due to NotAllowedException

---
 .../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 86ac74e8f17d1..ce9bf1ef0b0f7 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 @@ && isCompactionSubscription(subscriptionName)) {
                     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.warn("[{}][{}] Not allowed create subscription {}", topic, subscriptionName,
+                        ex.getCause().getMessage());
                 } else {
                     log.error("[{}] Failed to create subscription: {}", topic, subscriptionName, ex);
                 }