fix error when update topic

Author: 1782935682

common/src/main/java/org/apache/rocketmq/common/TopicConfig.java

@@ -22,6 +22,7 @@
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Objects;
+import org.apache.rocketmq.common.attribute.AttributeParser;
 import org.apache.rocketmq.common.attribute.TopicMessageType;
 import org.apache.rocketmq.common.constant.PermName;
 
@@ -203,7 +204,9 @@ public TopicMessageType getTopicMessageType() {
         if (attributes == null) {
             return TopicMessageType.NORMAL;
         }
-        String content = attributes.get(TOPIC_MESSAGE_TYPE_ATTRIBUTE.getName());
+        String content = attributes.get(TOPIC_MESSAGE_TYPE_ATTRIBUTE.getName()) == null
+            ? attributes.get(AttributeParser.ATTR_ADD_PLUS_SIGN + TOPIC_MESSAGE_TYPE_ATTRIBUTE.getName())
+            : attributes.get(TOPIC_MESSAGE_TYPE_ATTRIBUTE.getName());
         if (content == null) {
             return TopicMessageType.NORMAL;
         }
@@ -212,7 +215,7 @@ public TopicMessageType getTopicMessageType() {
 
     @JSONField(serialize = false, deserialize = false)
     public void setTopicMessageType(TopicMessageType topicMessageType) {
-        attributes.put(TOPIC_MESSAGE_TYPE_ATTRIBUTE.getName(), topicMessageType.getValue());
+        attributes.put(AttributeParser.ATTR_ADD_PLUS_SIGN + TOPIC_MESSAGE_TYPE_ATTRIBUTE.getName(), topicMessageType.getValue());
     }
 
     @Override
@@ -265,9 +268,6 @@ public int hashCode() {
 
     @Override
     public String toString() {
-        return "TopicConfig [topicName=" + topicName + ", readQueueNums=" + readQueueNums
-            + ", writeQueueNums=" + writeQueueNums + ", perm=" + PermName.perm2String(perm)
-            + ", topicFilterType=" + topicFilterType + ", topicSysFlag=" + topicSysFlag + ", order=" + order
-            + ", attributes=" + attributes + "]";
+        return "TopicConfig [topicName=" + topicName + ", readQueueNums=" + readQueueNums + ", writeQueueNums=" + writeQueueNums + ", perm=" + PermName.perm2String(perm) + ", topicFilterType=" + topicFilterType + ", topicSysFlag=" + topicSysFlag + ", order=" + order + ", attributes=" + attributes + "]";
     }
 }