Skip to content

Commit fcf0a08

Browse files
jiangminbingjiangmb
andauthored
[Bugfix] 修复BrokerConfigServiceImpl.getBrokerConfigByZKClient方法一定返回空的问题 (#1198)
修复获取ZK-Broker配置,出现空列表的问题 Co-authored-by: jiangmb <[email protected]>
1 parent 68839a6 commit fcf0a08

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@
3737

3838
import javax.annotation.PostConstruct;
3939
import java.util.*;
40+
import java.util.stream.Collectors;
4041

4142
import static com.xiaojukeji.know.streaming.km.common.enums.version.VersionEnum.*;
4243

@@ -154,9 +155,11 @@ private Result<List<KafkaConfigDetail>> getBrokerConfigByZKClient(VersionItemPar
154155
if (propertiesResult.failed()) {
155156
return Result.buildFromIgnoreData(propertiesResult);
156157
}
158+
List<String> configKeyList = propertiesResult.getData().keySet().stream().map(Object::toString).collect(Collectors.toList());
159+
157160

158161
return Result.buildSuc(KafkaConfigConverter.convert2KafkaBrokerConfigDetailList(
159-
new ArrayList<>(),
162+
configKeyList,
160163
propertiesResult.getData()
161164
));
162165
}

0 commit comments

Comments
 (0)