Skip to content

Commit ab3b83e

Browse files
authored
Merge pull request #539 from ruanliang-hualun/dev
备注与实现不一致,优先使用EXTERNAL_KEY
2 parents 4818629 + 61784c8 commit ab3b83e

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)