From 66d7fa0e17c6b94216d1bf1b1d1bd973d221a653 Mon Sep 17 00:00:00 2001 From: yechun Date: Wed, 11 Jan 2023 14:21:18 +0800 Subject: [PATCH] [ISSUE #137]Fix the bug of topic create or update when order is true --- .../rocketmq/dashboard/service/impl/TopicServiceImpl.java | 4 ++++ 1 file changed, 4 insertions(+) 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 9dfde72..22e95a3 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 @@ -124,6 +124,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) { throw Throwables.propagate(err);