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

dinglei 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 82b2f8eefa AddBroker removes parsing configuration from body (#7472)
82b2f8eefa is described below

commit 82b2f8eefac157843c6ccec80d94f202c06bd195
Author: rongtong <jinrongto...@163.com>
AuthorDate: Wed Oct 18 13:51:47 2023 +0800

    AddBroker removes parsing configuration from body (#7472)
---
 .../org/apache/rocketmq/container/BrokerContainerProcessor.java  | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git 
a/container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java
 
b/container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java
index 2ac69112d7..5b825fe811 100644
--- 
a/container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java
+++ 
b/container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java
@@ -91,11 +91,10 @@ public class BrokerContainerProcessor implements 
NettyRequestProcessor {
                 LOGGER.error("addBroker load config from {} failed, {}", 
configPath, e);
             }
         } else {
-            byte[] body = request.getBody();
-            if (body != null) {
-                String bodyStr = new String(body, MixAll.DEFAULT_CHARSET);
-                brokerProperties = MixAll.string2Properties(bodyStr);
-            }
+            LOGGER.error("addBroker config path is empty");
+            response.setCode(ResponseCode.SYSTEM_ERROR);
+            response.setRemark("addBroker config path is empty");
+            return response;
         }
 
         if (brokerProperties == null) {

Reply via email to