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 d6c26db1fe..3b20a730db 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 @@ public class DefaultMQAdminExtImpl implements MQAdminExt, MQAdminExtInner { @Override public void createTopic(String key, String newTopic, int queueNum, Map attributes) throws MQClientException { - createTopic(key, newTopic, queueNum, 0, null); + createTopic(key, newTopic, queueNum, 0, attributes); } @Override