Commit e1b78faf authored by 黎博's avatar 黎博

优化podList中kafka service信息获取

parent 1ea335f8
......@@ -244,6 +244,9 @@ public class TkeService {
// 遍历Service列表
for (Service service: serviceList) {
String serviceName = service.getMetadata().getName();
if (StringUtils.equals(serviceName, "kafka-" + namespace)) {
serviceName = "kafka";
}
podServiceMap = assign(serviceName, podServiceMap, formatServiceInfo(service));
}
// 遍历Ingress列表
......@@ -405,6 +408,10 @@ public class TkeService {
* @return
*/
public Service getServiceDetail(String namespace, String serviceName) {
// kafka Service name不能直接叫kafka,需要特殊处理一下
if (StringUtils.equals(serviceName, "kafka")) {
serviceName = "kafka-" + namespace;
}
return kubernetesClient.services().inNamespace(namespace).withName(serviceName).get();
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment