diff --git a/src/main/java/org/apache/rocketmq/dashboard/model/request/TopicConfigInfo.java b/src/main/java/org/apache/rocketmq/dashboard/model/request/TopicConfigInfo.java index 3069ee6..dbff83e 100644 --- a/src/main/java/org/apache/rocketmq/dashboard/model/request/TopicConfigInfo.java +++ b/src/main/java/org/apache/rocketmq/dashboard/model/request/TopicConfigInfo.java @@ -99,7 +99,7 @@ public class TopicConfigInfo { } public void setMessageType(TopicConfig topicConfig) { - this.messageType = topicConfig.getAttributes().getOrDefault("message.type", ""); + this.messageType = topicConfig.getAttributes().getOrDefault("message.type", "NORMAL"); } @Override diff --git a/src/main/resources/static/src/topic.js b/src/main/resources/static/src/topic.js index bf8760d..87c2719 100644 --- a/src/main/resources/static/src/topic.js +++ b/src/main/resources/static/src/topic.js @@ -333,7 +333,7 @@ module.controller('topicController', ['$scope', 'ngDialog', '$http', 'Notificati perm: 6, order: false, topicName: "", - messageType: "", + messageType: "NORMAL", brokerNameList: [] }]; bIsUpdate = false;