diff --git a/controller/src/main/java/org/apache/rocketmq/controller/impl/manager/SyncStateInfo.java b/controller/src/main/java/org/apache/rocketmq/controller/impl/manager/SyncStateInfo.java index dd846c28711..2674dabf547 100644 --- a/controller/src/main/java/org/apache/rocketmq/controller/impl/manager/SyncStateInfo.java +++ b/controller/src/main/java/org/apache/rocketmq/controller/impl/manager/SyncStateInfo.java @@ -18,6 +18,7 @@ import java.util.HashSet; import java.util.Set; +import org.apache.commons.lang3.StringUtils; /** * Manages the syncStateSet of broker replicas. @@ -53,7 +54,7 @@ public void updateSyncStateSetInfo(Set newSyncStateSet) { } public boolean isMasterExist() { - return masterAddress != null && !this.masterAddress.isEmpty(); + return !StringUtils.isBlank(masterAddress); } public String getClusterName() {