From 0753ba449cce0297b7e2d78a1c42f19a4feeabcc Mon Sep 17 00:00:00 2001 From: btlqql <2977859784@qq.com> Date: Thu, 13 Aug 2026 13:58:56 +0800 Subject: [PATCH] [ISSUE #10873] Guard BrokerData.selectBrokerAddr against empty address table --- .../apache/rocketmq/remoting/protocol/route/BrokerData.java | 3 +++ 1 file changed, 3 insertions(+) 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) {