GitHub user jevonsnotes edited a discussion: the expected type is FIFO, but actual type is NORMAL BROKER
为何我使用rocketmq-spring `发送消息时,总是提示实际broker为normal,请问是少了什么配置吗? 创建主题 ``` [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