diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/BrokerData.java b/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/BrokerData.java index de911d17c26..766cae3e421 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/BrokerData.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/BrokerData.java @@ -89,6 +89,9 @@ public BrokerData(String cluster, String brokerName, HashMap broke * @return Broker address. */ public String selectBrokerAddr() { + if (this.brokerAddrs == null || this.brokerAddrs.isEmpty()) { + return null; + } String masterAddress = this.brokerAddrs.get(MixAll.MASTER_ID); if (masterAddress == null) {