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 [email protected].
To unsubscribe, please send an email to: [email protected]