diff --git a/src/main/java/org/apache/rocketmq/dashboard/service/impl/TopicServiceImpl.java b/src/main/java/org/apache/rocketmq/dashboard/service/impl/TopicServiceImpl.java index 4f34fc6..bcece8f 100644 --- a/src/main/java/org/apache/rocketmq/dashboard/service/impl/TopicServiceImpl.java +++ b/src/main/java/org/apache/rocketmq/dashboard/service/impl/TopicServiceImpl.java @@ -182,6 +182,10 @@ public class TopicServiceImpl extends AbstractCommonService implements TopicServ for (String brokerName : changeToBrokerNameSet(clusterInfo.getClusterAddrTable(), topicCreateOrUpdateRequest.getClusterNameList(), topicCreateOrUpdateRequest.getBrokerNameList())) { mqAdminExt.createAndUpdateTopicConfig(clusterInfo.getBrokerAddrTable().get(brokerName).selectBrokerAddr(), topicConfig); + if (topicCreateOrUpdateRequest.isOrder()) { + String orderConf = brokerName + ":" + topicConfig.getWriteQueueNums(); + mqAdminExt.createOrUpdateOrderConf(topicConfig.getTopicName(), orderConf, false); + } } } catch (Exception err) { Throwables.throwIfUnchecked(err);