system/kafka: Added (high-throughput distributed messaging system).

Signed-off-by: Willy Sudiarto Raharjo <willysr@slackbuilds.org>

1 files changed, 40 insertions, 0 deletions

diff --git a/system/kafka/rc.kafka b/system/kafka/rc.kafka
new file mode 100644
index 000000000000..12d74bc8b739
--- /dev/null
+++ b/system/kafka/rc.kafka
@@ -0,0 +1,40 @@
+#!/bin/sh
+# Start/stop/restart Apache Zookeeper daemon
+
+SERVER_CONFIG=(server.properties)
+
+USER=kafka
+kafka_start(){
+  for conf in ${SERVER_CONFIG[@]}; do
+    sudo -u ${USER} sh -c "/usr/bin/kafka-server-start.sh -daemon /etc/kafka/${conf}"
+  done
+}
+
+kafka_stop() {
+  sudo -u ${USER} sh -c "/usr/bin/kafka-server-stop.sh"
+}
+
+kafka_restart() {
+  kafka_start
+  sleep 1
+  kafka_stop
+}
+
+print_usage() {
+  echo "usage $0 start|stop|restart"
+}
+
+case "$1" in
+  'start')
+    kafka_start
+    ;;
+  'stop')
+    kafka_stop
+    ;;
+  'restart')
+    kafka_restart
+    ;;
+  *)
+    print_usage
+    ;;
+esac