Skip to content

Commit a5d9f0c

Browse files
Technoboy-priyanshu-ctds
authored andcommitted
[improve][broker] Change the log level from error to info when throwing NotAllowedException (apache#25130)
(cherry picked from commit b474a8d)
1 parent 428abcc commit a5d9f0c

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1086,6 +1086,9 @@ && isCompactionSubscription(subscriptionName)) {
10861086
close();
10871087
} else if (ex.getCause() instanceof BrokerServiceException.ConnectionClosedException) {
10881088
log.warn("[{}][{}] Connection was closed while the opening the cursor", topic, subscriptionName);
1089+
} else if (ex.getCause() instanceof BrokerServiceException.NotAllowedException) {
1090+
log.info("[{}][{}] Not allowed to create subscription: {}", topic, subscriptionName,
1091+
ex.getCause().getMessage());
10891092
} else {
10901093
log.error("[{}] Failed to create subscription: {}", topic, subscriptionName, ex);
10911094
}

0 commit comments

Comments
 (0)