From 61784c860a31a95f8d2d9373892037fda4cb07d3 Mon Sep 17 00:00:00 2001 From: ruanliang01 Date: Thu, 1 Sep 2022 21:07:15 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A4=87=E6=B3=A8=E4=B8=8E=E5=AE=9E=E7=8E=B0?= =?UTF-8?q?=E4=B8=8D=E4=B8=80=E8=87=B4=EF=BC=8C=E4=BC=98=E5=85=88=E4=BD=BF?= =?UTF-8?q?=E7=94=A8EXTERNAL=5FKEY?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../km/common/zookeeper/znode/brokers/BrokerMetadata.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/zookeeper/znode/brokers/BrokerMetadata.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/zookeeper/znode/brokers/BrokerMetadata.java index 1f598091..480867af 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/zookeeper/znode/brokers/BrokerMetadata.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/zookeeper/znode/brokers/BrokerMetadata.java @@ -113,7 +113,7 @@ public class BrokerMetadata implements Serializable { brokerMetadata.getEndpointMap().put(endpoint.substring(0, idx1), new IpPortData(brokerHost, brokerPort)); - if (KafkaConstant.EXTERNAL_KEY.equals(endpoint.substring(0, idx1))) { + if (KafkaConstant.INTERNAL_KEY.equals(endpoint.substring(0, idx1))) { // 优先使用internal的地址进行展示 brokerMetadata.setHost(brokerHost); brokerMetadata.setPort(ConvertUtil.string2Integer(brokerPort));