GitHub user dx8439 closed a discussion: rocketmq集群开启自动创建topic无效

rocketmq集群开启自动创建topic,autoCreateTopicEnable=true,版本4.6.1,但是,但是服务发送消息报错没有topic。

See http://rocketmq.apache.org/docs/faq/ for further details.
        at 
com.runjing.rocketmq.RocketMQProducer.defaultSend(RocketMQProducer.java:83)
        at com.runjing.rocketmq.RocketMQProducer.send(RocketMQProducer.java:39)
Caused by: org.apache.rocketmq.client.exception.MQClientException: Send [3] 
times, still failed, cost [19]ms, Topic: qa_npos_order_topic, BrokersSent: 
[broker-b, broker-c, broker-b]
See http://rocketmq.apache.org/docs/faq/ for further details.
        at 
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:664)
        at 
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1342)
        at 
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1288)
        at 
org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:324)
        at 
com.runjing.rocketmq.RocketMQProducer.defaultSend(RocketMQProducer.java:74)
Caused by: org.apache.rocketmq.client.exception.MQBrokerException: CODE: 17  
DESC: topic[qa_npos_order_topic] not exist, apply first please!
See http://rocketmq.apache.org/docs/faq/ for further details.
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.processSendResponse(MQClientAPIImpl.java:709)
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:505)
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage$original$Qgg6jAJC(MQClientAPIImpl.java:487)
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage$original$Qgg6jAJC$accessor$NP6ZQ0nc(MQClientAPIImpl.java)
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl$auxiliary$TIHU8dxv.call(Unknown 
Source)
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java)
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:431)
        at 
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:853)
        at 
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:583)

GitHub link: https://github.com/apache/rocketmq/discussions/7588

----
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