AddBroker removes parsing configuration from body (#7472)

apache · Oct 18, 2023 · 82b2f8e · 82b2f8e
1 parent d73b601
commit 82b2f8e
Showing 1 changed file with 4 additions and 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
@@ -91,11 +91,10 @@ private synchronized RemotingCommand addBroker(ChannelHandlerContext ctx,
                 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) {