Skip to content

Commit 61784c8

Browse files
author
ruanliang01
committed
备注与实现不一致,优先使用EXTERNAL_KEY
1 parent 69cd1ff commit 61784c8

File tree

1 file changed

+1
-1
lines changed
  • km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/zookeeper/znode/brokers

1 file changed

+1
-1
lines changed

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/zookeeper/znode/brokers/BrokerMetadata.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -113,7 +113,7 @@ public static void parseAndUpdateBrokerMetadata(BrokerMetadata brokerMetadata) {
113113

114114
brokerMetadata.getEndpointMap().put(endpoint.substring(0, idx1), new IpPortData(brokerHost, brokerPort));
115115

116-
if (KafkaConstant.EXTERNAL_KEY.equals(endpoint.substring(0, idx1))) {
116+
if (KafkaConstant.INTERNAL_KEY.equals(endpoint.substring(0, idx1))) {
117117
// 优先使用internal的地址进行展示
118118
brokerMetadata.setHost(brokerHost);
119119
brokerMetadata.setPort(ConvertUtil.string2Integer(brokerPort));

0 commit comments

Comments
 (0)