diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java index 796b72ef273abe22ca74819f0946b678293a367c..e649665ad4d77b78216e1ca03f5542e5643de5eb 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java @@ -508,6 +508,7 @@ public class BrokerController { @Override public void doBeforeRequest(String remoteAddr, RemotingCommand request) { + //Do not catch the exception validator.validate(validator.parse(request, remoteAddr)); }