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); }