From fcf0a08e0a3c4ba78576c8b5b253affa02068d4b Mon Sep 17 00:00:00 2001 From: jiangminbing Date: Sat, 6 Jan 2024 16:40:11 +0800 Subject: [PATCH] =?UTF-8?q?[Bugfix]=20=E4=BF=AE=E5=A4=8DBrokerConfigServic?= =?UTF-8?q?eImpl.getBrokerConfigByZKClient=E6=96=B9=E6=B3=95=E4=B8=80?= =?UTF-8?q?=E5=AE=9A=E8=BF=94=E5=9B=9E=E7=A9=BA=E7=9A=84=E9=97=AE=E9=A2=98?= =?UTF-8?q?=20(#1198)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 修复获取ZK-Broker配置，出现空列表的问题 Co-authored-by: jiangmb --- .../km/core/service/broker/impl/BrokerConfigServiceImpl.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java index aa2bb7eca..1007cb270 100644 --- a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java +++ b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java @@ -37,6 +37,7 @@ import javax.annotation.PostConstruct; import java.util.*; +import java.util.stream.Collectors; import static com.xiaojukeji.know.streaming.km.common.enums.version.VersionEnum.*; @@ -154,9 +155,11 @@ private Result> getBrokerConfigByZKClient(VersionItemPar if (propertiesResult.failed()) { return Result.buildFromIgnoreData(propertiesResult); } + List configKeyList = propertiesResult.getData().keySet().stream().map(Object::toString).collect(Collectors.toList()); + return Result.buildSuc(KafkaConfigConverter.convert2KafkaBrokerConfigDetailList( - new ArrayList<>(), + configKeyList, propertiesResult.getData() )); }