diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/broker/Broker.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/broker/Broker.java
index d7e3b792..fa67cac5 100644
--- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/broker/Broker.java
+++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/broker/Broker.java
@@ -111,7 +111,7 @@ public class Broker implements Serializable {
             return host;
         }
         IpPortData ip = endpointMap.get(endPoint);
-        return ip == null ? ip.getIp() : host;
+        return ip != null ? ip.getIp() : host;
     }
 
     public boolean alive() {