diff --git a/eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/store/RocketmqTopicCore.java b/eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/store/RocketmqTopicCore.java
index c9387128..b3810f0c 100644
--- a/eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/store/RocketmqTopicCore.java
+++ b/eventmesh-dashboard-core/src/main/java/org/apache/eventmesh/dashboard/core/store/RocketmqTopicCore.java
@@ -67,8 +67,6 @@ public RocketmqTopicCore(RocketmqProperties rocketmqProperties) {
     public Boolean createTopic(String topicName) {
         String namesrvAddr = rocketmqProperties.getNamesrvAddr();
         long requestTimeoutMillis = rocketmqProperties.getRequestTimeoutMillis();
-        int readQueueNums = rocketmqProperties.getReadQueueNums();
-        int writeQueueNums = rocketmqProperties.getReadQueueNums();
         if (StringUtils.isEmpty(namesrvAddr)) {
             log.info("RocketmqTopicCore-createTopic failed, missing brokerUrl");
             return Boolean.FALSE;
@@ -82,8 +80,6 @@ public Boolean createTopic(String topicName) {
             CreateTopicRequestHeader requestHeader = new CreateTopicRequestHeader();
             requestHeader.setTopic(topicName);
             requestHeader.setTopicFilterType(TopicFilterType.SINGLE_TAG.name());
-            requestHeader.setReadQueueNums(readQueueNums);
-            requestHeader.setWriteQueueNums(writeQueueNums);
             requestHeader.setPerm(PermName.PERM_READ | PermName.PERM_WRITE);
 
             RemotingCommand request = RemotingCommand.createRequestCommand(RequestCode.UPDATE_AND_CREATE_TOPIC, requestHeader);