删除kafka Service特殊处理

5bc6c7bc · 黎博 · a3ee26c4 · 5bc6c7bc
Commit 5bc6c7bc authored Apr 19, 2022 by 黎博
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 0 deletions

TkeService.java src/main/java/cn/qg/holmes/service/k8s/TkeService.java +4 -0

No files found.
--- a/src/main/java/cn/qg/holmes/service/k8s/TkeService.java
+++ b/src/main/java/cn/qg/holmes/service/k8s/TkeService.java
@@ -512,6 +512,10 @@ public class TkeService {
    }
    public boolean deleteService(String namespace, String serviceName) {
+        // kafka Service需要特殊处理一下
+        if (StringUtils.equals("kafka", serviceName)) {
+            return kubernetesClient.services().inNamespace(namespace).withName("kafka-" + namespace).delete();
+        }
        return kubernetesClient.services().inNamespace(namespace).withName(serviceName).delete();
    }