8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-24 11:52:08 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

服务发现接口修复

Browse Source
This commit is contained in:
zengqiao
2020-11-08 15:59:50 +08:00
parent 03467196b9
commit daee57167b
1 changed files with 18 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
kafka-manager-web/src/main/java/com/xiaojukeji/kafka/manager/web/api/versionone/gateway/GatewayServiceDiscoveryController.java
View File

@@ -60,6 +60,9 @@ public class GatewayServiceDiscoveryController {
if (ValidateUtils.isNull(config) || ValidateUtils.isNull(config.getClusterIdBootstrapServersMap())) { if (ValidateUtils.isNull(config) || ValidateUtils.isNull(config.getClusterIdBootstrapServersMap())) {
return Result.buildFailure("call init kafka bootstrap servers failed"); return Result.buildFailure("call init kafka bootstrap servers failed");
} }
if (ValidateUtils.isEmptyMap(config.getClusterIdBootstrapServersMap())) {
return Result.buildSuc();
}
return Result.buildSuc(JSON.toJSONString(config.getClusterIdBootstrapServersMap())); return Result.buildSuc(JSON.toJSONString(config.getClusterIdBootstrapServersMap()));
} }
@@ -73,7 +76,9 @@ public class GatewayServiceDiscoveryController {
if (ValidateUtils.isNull(config) || ValidateUtils.isNull(config.getClusterIdBootstrapServersMap())) { if (ValidateUtils.isNull(config) || ValidateUtils.isNull(config.getClusterIdBootstrapServersMap())) {
return Result.buildFailure("call update kafka bootstrap servers failed"); return Result.buildFailure("call update kafka bootstrap servers failed");
} }
if (ValidateUtils.isEmptyMap(config.getClusterIdBootstrapServersMap())) {
return Result.buildSuc();
}
return Result.buildSuc(JSON.toJSONString(new GatewayConfigVO( return Result.buildSuc(JSON.toJSONString(new GatewayConfigVO(
String.valueOf(config.getVersion()), String.valueOf(config.getVersion()),
JSON.toJSONString(config.getClusterIdBootstrapServersMap()) JSON.toJSONString(config.getClusterIdBootstrapServersMap())
@@ -89,7 +94,9 @@ public class GatewayServiceDiscoveryController {
if (ValidateUtils.isNull(config)) { if (ValidateUtils.isNull(config)) {
return Result.buildFailure("call get request queue size config failed"); return Result.buildFailure("call get request queue size config failed");
} }
if (ValidateUtils.isNull(config.getMaxRequestQueueSize())) {
return Result.buildSuc();
}
return Result.buildSuc(JSON.toJSONString( return Result.buildSuc(JSON.toJSONString(
new GatewayConfigVO( new GatewayConfigVO(
String.valueOf(config.getVersion()), String.valueOf(config.getVersion()),
@@ -107,7 +114,9 @@ public class GatewayServiceDiscoveryController {
if (ValidateUtils.isNull(config)) { if (ValidateUtils.isNull(config)) {
return Result.buildFailure("call get app rate config failed"); return Result.buildFailure("call get app rate config failed");
} }
if (ValidateUtils.isNull(config.getAppRateLimit())) {
return Result.buildSuc();
}
return Result.buildSuc(JSON.toJSONString( return Result.buildSuc(JSON.toJSONString(
new GatewayConfigVO( new GatewayConfigVO(
String.valueOf(config.getVersion()), String.valueOf(config.getVersion()),
@@ -125,6 +134,9 @@ public class GatewayServiceDiscoveryController {
if (ValidateUtils.isNull(config)) { if (ValidateUtils.isNull(config)) {
return Result.buildFailure("call get ip rate config failed"); return Result.buildFailure("call get ip rate config failed");
} }
if (ValidateUtils.isNull(config.getIpRateLimit())) {
return Result.buildSuc();
}
return Result.buildSuc(JSON.toJSONString( return Result.buildSuc(JSON.toJSONString(
new GatewayConfigVO( new GatewayConfigVO(
String.valueOf(config.getVersion()), String.valueOf(config.getVersion()),
@@ -143,7 +155,9 @@ public class GatewayServiceDiscoveryController {
if (ValidateUtils.isNull(config) || ValidateUtils.isNull(config.getSpRateMap())) { if (ValidateUtils.isNull(config) || ValidateUtils.isNull(config.getSpRateMap())) {
return Result.buildFailure("call update kafka bootstrap servers failed"); return Result.buildFailure("call update kafka bootstrap servers failed");
} }
if (ValidateUtils.isEmptyMap(config.getSpRateMap())) {
return Result.buildSuc();
}
List<String> strList = new ArrayList<>(); List<String> strList = new ArrayList<>();
for (Map.Entry<String, Long> entry: config.getSpRateMap().entrySet()) { for (Map.Entry<String, Long> entry: config.getSpRateMap().entrySet()) {
strList.add(entry.getKey() + "#" + String.valueOf(entry.getValue())); strList.add(entry.getKey() + "#" + String.valueOf(entry.getValue()));