kaushik-develop commented on a change in pull request #11524:
URL: https://github.com/apache/pulsar/pull/11524#discussion_r680246016
##########
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
##########
@@ -2364,7 +2365,12 @@ public ByteBufPair newMessageAndIntercept(long
consumerId, long ledgerId, long e
ackSet);
ByteBufPair res = Commands.serializeCommandMessageWithSize(command,
metadataAndPayload);
try {
- getBrokerService().getInterceptor().onPulsarCommand(command, this);
+ val brokerInterceptor = getBrokerService().getInterceptor();
+ if (brokerInterceptor != null) {
+ brokerInterceptor.onPulsarCommand(command, this);
+ } else {
Review comment:
Since it is a debug thing, I hope it's ok to leave it there -- just in
the unlikely case anyone was depending on an exception being raised. PLMK if
you feel strongly otherwise.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
