diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java index fc3b6182731..4c341dde920 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java @@ -886,6 +886,12 @@ private RemotingCommand getBrokerAclConfigVersion(ChannelHandlerContext ctx, Rem final RemotingCommand response = RemotingCommand.createResponseCommand(GetBrokerAclConfigResponseHeader.class); + if (!brokerController.getBrokerConfig().isAclEnable()) { + response.setCode(ResponseCode.SYSTEM_ERROR); + response.setRemark("The broker does not enable acl."); + return response; + } + final GetBrokerAclConfigResponseHeader responseHeader = (GetBrokerAclConfigResponseHeader) response.readCustomHeader(); try {