Replies: 2 comments
-
创建时报错,Create new topic failed, because the default topic[TBW102] has no perm [6],但我看了下topic列表,有名为TBW102的topic,配置如下:brokerClusterName=runjing-test-Cluster brokerClusterName=runjing-test-Cluster broker-b和broker-c配置类似 |
Beta Was this translation helpful? Give feedback.
-
TBW102正常权限应该为7 |
Beta Was this translation helpful? Give feedback.
Uh oh!
There was an error while loading. Please reload this page.
-
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)
Beta Was this translation helpful? Give feedback.
All reactions