GitHub user jevonsnotes edited a discussion: the expected type is FIFO, but 
actual type is NORMAL BROKER

为何我使用rocketmq-spring `发送消息时,总是提示实际broker为normal,请问是少了什么配置吗?
mq版本
`5.2.0`

创建主题
```
[root@gd4400-tst-tyzj-kylin-ecs-0019 bin]# ./mqadmin updateTopic -n 
10.26.22.29:9876 -c DefaultCluster -t TOPIC_FIFO  -o true -a +message.type=FIFO
create topic to 10.26.22.29:10911 success.
set cluster orderConf. isOrder=true, orderConf=[broker-a:8]
TopicConfig [topicName=TOPIC_FIFO, readQueueNums=8, writeQueueNums=8, perm=RW-, 
topicFilterType=SINGLE_TAG, topicSysFlag=0, order=true, 
attributes={+message.type=FIFO}]
```

发送方法
```
    /**
     * 发送顺序消息
     *
     * @param message
     * @param topic
     * @param hashKey
     */
    public void syncSendOrderly(String topic, Object message, String hashKey) {
        log.info("发送顺序消息,topic:" + topic + ",hashKey:" + hashKey);
        rocketMQTemplate.syncSendOrderly(topic, message, hashKey);
    }
```

报错
```
org.apache.rocketmq.client.exception.MQBrokerException: CODE: 13  DESC: 
TopicMessageType validate failed, the expected type is FIFO, but actual type is 
NORMAL BROKER: 10.26.22.29:8080
For more information, please visit the url, 
https://rocketmq.apache.org/docs/bestPractice/06FAQ
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.processSendResponse(MQClientAPIImpl.java:774)
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:610)
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:592)
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:536)
        at 
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:1016)
        at 
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendSelectImpl(DefaultMQProducerImpl.java:1309)
        at 
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1275)
        at 
org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:669)
        at 
org.apache.rocketmq.spring.core.RocketMQTemplate.syncSendOrderly(RocketMQTemplate.java:769)
```

GitHub link: https://github.com/apache/rocketmq-clients/discussions/785

----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org

Reply via email to