kafka新增健康检查

src/main/java/cn/qg/holmes/service/k8s/K8sService.java

@@ -2314,6 +2314,12 @@ public class K8sService {
         List<EnvVar> envVarList = new ArrayList<>();
         envVarList.addAll(Arrays.asList(envVar1, envVar2, envVar3, envVar4, envVar5, envVar6));
 
+        Probe livenessProbe = new ProbeBuilder().withTcpSocket(
+                new TCPSocketActionBuilder().withPort(
+                        new IntOrStringBuilder().withIntVal(9092).build())
+                        .build())
+                .build();
+
         Container container = new ContainerBuilder()
                 .withName("kafka")
                 .withImage("ccr.ccs.tencentyun.com/" + image)
@@ -2328,6 +2334,7 @@ public class K8sService {
                                 .withName("datadir")
                                 .withMountPath("/var/lib/kafka")
                                 .build())
+                .withLivenessProbe(livenessProbe)
                 .build();
 
         List<Container> containerList = new ArrayList<>();