手動創建后仍然提示 topic[] not exist, apply first please


       昨天晚上同事碰到個問題,rocketMq 在test和dev環境創建的topic ,默認是自動創建的沒有問題,但是在pre環境卻不行。日志里面提示是 

     

com.alibaba.rocketmq.client.exception.MQClientException: Send [5] times, still failed, cost [24]ms, Topic: astrict_driver_refresh_crowd, BrokersSent: [broker-a, broker-b, broker-a, broker-b, broker-a]
See http://docs.aliyun.com/cn#/pub/ons/faq/exceptions&send_msg_failed for further details.
    at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:577)
    at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1034)
    at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1028)
    at com.alibaba.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:101)
    at com.zhuanche.common.rocketmq.CommonRocketProducer.publishMessage(CommonRocketProducer.java:69)
    at com.zhuanche.service.mpconfig.AstrictDriverRefreshCrowdService.refreshDriverCrowd(AstrictDriverRefreshCrowdService.java:74)
    at com.zhuanche.controller.config.AstrictDriverNotifyController$4.run(AstrictDriverNotifyController.java:101)
    at java.lang.Thread.run(Thread.java:745)
Caused by: com.alibaba.rocketmq.client.exception.MQBrokerException: CODE: 17  DESC: topic[astrict_driver_refresh_crowd] not exist, apply first please!
See http://rocketmq.apache.org/docs/faq/ for further details.
    at com.alibaba.rocketmq.client.impl.MQClientAPIImpl.processSendResponse(MQClientAPIImpl.java:345)
    at com.alibaba.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:255)
    at com.alibaba.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:236)
    at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:682)
[dev@cn_bj_sjhl_docker-pre-g1_10-30-11-21 mp-config-rest_10.30.11.248]$ Connection to ops-jump1.01zhuanche.com closed by remote host.

    就是沒有找到對應的topic,按說應該是自動創建的,但是手動創建后仍然不行。

   這好奇怪。  最后是通過添加了 instanceName 解決了,但是這里面的邏輯自己仍然沒有理清楚。

  參考:https://www.jianshu.com/p/c8fd57a7f741


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM