Why I can't update TopicConfig by DefaultMQAdminExt?

[powertoredstar]

my operations as follows:
1.create a topic by createTopic method
2.create a topicConfig I want to update
3.get all broker ip
4.update topicConfig on each broker

    @Test
    public void createTopic() throws MQClientException, MQBrokerException, RemotingException, InterruptedException {
        DefaultMQAdminExt admin = new DefaultMQAdminExt();
        admin.setNamesrvAddr("10.30.18.78:19876");
        admin.start();
        String clusterName = "DefaultCluster";
        String topicName = "AI-CHAT-TOPIC";
        admin.createTopic(clusterName, topicName, 1, null);
        TopicRouteData topicRouteData = admin.examineTopicRouteInfo(topicName);
        TopicConfig topicConfig = new TopicConfig();
        topicConfig.setTopicName(topicName);
        topicConfig.setTopicSysFlag(0);
        topicConfig.setPerm(6);
        topicConfig.setWriteQueueNums(1);
        topicConfig.setReadQueueNums(1);
        topicConfig.setTopicMessageType(TopicMessageType.FIFO);
        topicConfig.setOrder( true);
        List<BrokerData> brokerDatas = topicRouteData.getBrokerDatas();
        for(BrokerData brokerData: brokerDatas){
            System.out.println(brokerData.getBrokerName() + ":" + brokerData.getBrokerAddrs());
            String brokerIp = brokerData.selectBrokerAddr();
            System.out.println("brokerId:"+brokerIp);
            admin.createAndUpdateTopicConfig(brokerIp, topicConfig);
        }
        admin.shutdown();
    }

but I encounted an error on admin.createAndUpdateTopicConfig(brokerIp, topicConfig);

broker-b:{0=10.30.18.78:31911}
brokerId:10.30.18.78:31911

org.apache.rocketmq.client.exception.MQClientException: CODE: 1  DESC: add/alter attribute format is wrong: message.type
For more information, please visit the url, https://rocketmq.apache.org/docs/bestPractice/06FAQ

	at org.apache.rocketmq.client.impl.MQClientAPIImpl.createTopic(MQClientAPIImpl.java:452)
	at org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl.createAndUpdateTopicConfig(DefaultMQAdminExtImpl.java:258)
	at org.apache.rocketmq.tools.admin.DefaultMQAdminExt.createAndUpdateTopicConfig(DefaultMQAdminExt.java:202)
	at TopicManagerExample.createTopic(TopicManagerExample.java:57)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

why the attribute format is wrong: message.type?
My main purpose is to change the message type after I create a topic manually.

[powertoredstar]

the version is 5.3.2

[powertoredstar]

I know how to change the message type by setting the attribute when I create a topic now.But I still can't realize why I change the topicConfig is wrong.

DefaultMQAdminExt admin = new DefaultMQAdminExt();
        admin.setNamesrvAddr("10.30.18.78:19876");
        admin.start();
        String clusterName = "DefaultCluster";
        String topicName = "AI-CHAT-TOPIC";
        Map<String, String> map = new HashMap<>();
        admin.deleteTopic(topicName,clusterName);
        map.put("+message.type", MessageType.FIFO.name());
        System.out.println(MessageType.FIFO.name());
        admin.createTopic(clusterName, topicName, 1, map);

[SweetAAAAAA]

It appears that the method TopicConfig.setTopicMessageType is assigning the key message.type instead of +message.type to the attributes. The relevant code can be found at TopicConfig.java:L214 and TOPIC_MESSAGE_TYPE_ATTRIBUTE:L41. Inside the broker, when setting the message type for a queue, the broker reads the attributes and needs to prepend a plus sign to them. The relevant code for this is at msgTypeAttrKey:585.