[Bugfix] 修复BrokerConfigServiceImpl类中的getBrokerConfigByZKClient方法一定返回空…

…列表 (#1086)
didi · Nov 28, 2023 · bd7f4b2 · bd7f4b2
1 parent b6ea4ae
commit bd7f4b2
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...va/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java b/...va/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<List<KafkaConfigDetail>> getBrokerConfigByZKClient(VersionItemPar
         if (propertiesResult.failed()) {
             return Result.buildFromIgnoreData(propertiesResult);
         }
+        List<String> configKeyList = propertiesResult.getData().keySet().stream().map(Object::toString).collect(Collectors.toList());
+
 
         return Result.buildSuc(KafkaConfigConverter.convert2KafkaBrokerConfigDetailList(
-                new ArrayList<>(),
+                configKeyList,
                 propertiesResult.getData()
         ));
     }