Merge pull request #207 from Yolean/kafka-stop-hook

Send Kafka a TERM signal at pod stop and wait for shutdown
Yolean · Nov 18, 2018 · 198666d · 198666d
2 parents 727899a + 72ca76d
commit 198666d
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 0 deletions.
diff --git a/kafka/50kafka.yml b/kafka/50kafka.yml
@@ -58,6 +58,10 @@ spec:
         command:
         - ./bin/kafka-server-start.sh
         - /etc/kafka/server.properties
+        lifecycle:
+          preStop:
+            exec:
+             command: ["sh", "-ce", "kill -s TERM 1; while $(kill -0 1 2>/dev/null); do sleep 1; done"]
         resources:
           requests:
             cpu: 100m

diff --git a/zookeeper/50pzoo.yml b/zookeeper/50pzoo.yml
@@ -40,6 +40,10 @@ spec:
         command:
         - ./bin/zookeeper-server-start.sh
         - /etc/kafka/zookeeper.properties
+        lifecycle:
+          preStop:
+            exec:
+             command: ["sh", "-ce", "kill -s TERM 1; while $(kill -0 1 2>/dev/null); do sleep 1; done"]
         ports:
         - containerPort: 2181
           name: client

diff --git a/zookeeper/51zoo.yml b/zookeeper/51zoo.yml
@@ -43,6 +43,10 @@ spec:
         command:
         - ./bin/zookeeper-server-start.sh
         - /etc/kafka/zookeeper.properties
+        lifecycle:
+          preStop:
+            exec:
+             command: ["sh", "-ce", "kill -s TERM 1; while $(kill -0 1 2>/dev/null); do sleep 1; done"]
         ports:
         - containerPort: 2181
           name: client