Merge 66d7fa0e17 into 2fb0fce0b1

[ISSUE #137 ]Fix the bug of topic create or update when order is true
2026-06-09 06:13:18 +08:00 · 2024-05-09 16:34:36 +08:00 · 2023-01-11 14:22:41 +08:00
1 changed files with 4 additions and 0 deletions
--- a/src/main/java/org/apache/rocketmq/dashboard/service/impl/TopicServiceImpl.java
+++ b/src/main/java/org/apache/rocketmq/dashboard/service/impl/TopicServiceImpl.java
@@ -128,6 +128,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);
Author	SHA1	Message	Date
Slideee	e45988643a	Merge `66d7fa0e17` into `2fb0fce0b1`	2024-05-09 16:34:36 +08:00
yechun	66d7fa0e17	[ISSUE #137 ]Fix the bug of topic create or update when order is true	2023-01-11 14:22:41 +08:00