/k8s/listEnvVars特殊处理kafka

src/main/java/cn/qg/qaplatform/utils/K8sService.java

@@ -9,6 +9,7 @@ import io.fabric8.kubernetes.client.Config;
 import io.fabric8.kubernetes.client.DefaultKubernetesClient;
 import io.fabric8.kubernetes.client.KubernetesClient;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.core.io.ClassPathResource;
 import org.springframework.stereotype.Component;
 
@@ -79,7 +80,13 @@ public class K8sService {
         }
         // 遍历Service列表
         for (Service service: serviceList) {
-            String serviceName = service.getMetadata().getName().toUpperCase().replaceAll("-", "_");
+            String serviceName = service.getMetadata().getName();
+            // kafka Service Name 需要特殊处理一下
+            if (StringUtils.equals(serviceName, "kafka-" + namespace)) {
+                serviceName = "kafka";
+            }
+            // 转换成大写，并将-替换成下划线
+            serviceName = serviceName.toUpperCase().replaceAll("-", "_");
             List<ServicePort> servicePortList = service.getSpec().getPorts();
             if (service.getMetadata().getLabels().get("type").equals("base")) {
                 if (servicePortList.get(0).getPort() != null) {