使用RocketMQ發送消息拋出異常,異常如下:
原因:
Broker 禁止自動創建Topic,且用戶沒有通過手動創建此Topic,或者broker 和 Nameserver網絡不通;
解決方案:
1. 修改broker.properties配置,自動創建topic,添加如下:
autoCreateTopicEnable=true
2. 升級RocketMQ版本為4.4.0,新版本會默認自動創建
<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>4.4.0</version> </dependency>