fix: liveness and readiness probes added to k8s specs

danielqsj · Feb 24, 2021 · 450968d · 450968d
1 parent 61a00f5
commit 450968d
Show file tree

Hide file tree

Showing 2 changed files with 25 additions and 0 deletions.
diff --git a/charts/kafka-exporter/templates/deployment.yaml b/charts/kafka-exporter/templates/deployment.yaml
@@ -56,6 +56,27 @@ spec:
             - name: metrics
               containerPort: 9308
               protocol: TCP
+          livenessProbe:
+            failureThreshold: 1
+            httpGet:
+              path: /healthz
+              port: metrics
+              scheme: HTTP
+            initialDelaySeconds: 3
+            periodSeconds: 30
+            successThreshold: 1
+            timeoutSeconds: 9
+          readinessProbe:
+            failureThreshold: 1
+            httpGet:
+              path: /healthz
+              port: metrics
+              scheme: HTTP
+            initialDelaySeconds: 3
+            periodSeconds: 15
+            successThreshold: 1
+            timeoutSeconds: 9
+
           {{- if .Values.kafkaExporter.tls.enabled }}
           volumeMounts:
           - name: tls-certs

diff --git a/kafka_exporter.go b/kafka_exporter.go
@@ -637,6 +637,10 @@ func main() {
 	        </body>
 	        </html>`))
 	})
+	http.HandleFunc("/healthz", func(w http.ResponseWriter, r *http.Request) {
+		// need more specific sarama check
+		w.Write([]byte("ok"))
+	})
 
 	plog.Infoln("Listening on", *listenAddress)
 	plog.Fatal(http.ListenAndServe(*listenAddress, nil))