remove params

scwlkq · Mar 29, 2024 · 5a3939b · 5a3939b
1 parent 17a9b3f
commit 5a3939b
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/...board-core/src/main/java/org/apache/eventmesh/dashboard/core/store/RocketmqTopicCore.java b/...board-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);