报错:
本人在配置中设置了 autoCreateTopicEnable=true autoCreateSubscriptionGroup=true,并确认了网络之间是通的,但依然存在一下报错
Exception in thread "main" org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, topic_test_one_way_3 See http://rocketmq.apache.org/docs/faq/ for further details. at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:656) at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendOneway(DefaultMQProducerImpl.java:927) at org.apache.rocketmq.client.producer.DefaultMQProducer.sendOneway(DefaultMQProducer.java:354) at com.liliming.rocketmq.OnewayProducer.main(OnewayProducer.java:22)
原因:
经排查发现是因为系统默认的一个 Topic(TBW102)被删掉了,默认开启允许自动创建 Topic 主题的情况下,brocker 启动时会自动创建一个名称为 TBW102 的默认 Topic,生产这就是利用这个 Topic 来进行自动创建其他 topic 的。
尝试手动添加这个主题,结果报冲突,添加不了
解决办法:
1、重启 mq
2、手动在平台添加自己需要的主题