commit 48fab975e40cf963f46aab40521b326b0b5600d1
author Humkum <1109939087@qq.com> Wed Nov 16 20:28:29 2022 +0800
committer GitHub <noreply@github.com> Wed Nov 16 20:28:29 2022 +0800
tree 0533d46a87e31cd3868ade44468c5bfc5feb0582
parent b39f687f11b51dbd6a116bc91726ce12a1ec4b74

Fix : the topic attribute will be replace by null (#5527)

tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java

diff --git a/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java b/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
index d6c26db..3b20a73 100644
--- a/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
+++ b/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
@@ -1651,7 +1651,7 @@
     @Override
     public void createTopic(String key, String newTopic, int queueNum,
         Map<String, String> attributes) throws MQClientException {
-        createTopic(key, newTopic, queueNum, 0, null);
+        createTopic(key, newTopic, queueNum, 0, attributes);
     }
 
     @Override