(rocketmq) branch develop updated: [ISSUE #9014] Fix clusterAclConfigVersion command execution failed (#9017)

[dongyuanpan]

This is an automated email from the ASF dual-hosted git repository.

dongyuanpan pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new e104c02d50 [ISSUE #9014] Fix clusterAclConfigVersion command execution 
failed (#9017)
e104c02d50 is described below

commit e104c02d50758dacff00429d5e00458523c866f3
Author: yx9o <yangx_s...@163.com>
AuthorDate: Tue Dec 3 09:56:40 2024 +0800

    [ISSUE #9014] Fix clusterAclConfigVersion command execution failed (#9017)
---
 .../org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java  | 6 ++++++
 1 file changed, 6 insertions(+)

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 fc3b618273..4c341dde92 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 @@ public class AdminBrokerProcessor implements 
NettyRequestProcessor {
 
         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 {