2 files changed, 90 insertions, 0 deletions
diff --git a/net/kafka/files/kafka.in b/net/kafka/files/kafka.in
new file mode 100644
index 000000000000..70f28df363f7
--- /dev/null
+++ b/net/kafka/files/kafka.in
@@ -0,0 +1,74 @@
+#!/bin/sh
+# $FreeBSD$
+#
+# PROVIDE: kafka
+# REQUIRE: LOGIN
+# KEYWORD: shutdown
+#
+# Add kafka_enable="YES" to /etc/rc.conf to enable Kafka:
+#
+# Additional variables you can define are:
+#
+# kafka_user:		Username to run Kafka
+#			Default: %%USERS%%
+# kafka_group:		Groupname to run Kafka
+#			Default: %%GROUPS%%
+# kafka_config:		Configuration file to run Kafka
+#			Default: %%ETCDIR%%/server.properties
+# kafka_log4jprofile:	Profile for Kafka logging
+#			Default: %%ETCDIR%%/log4j.properties
+# kafka_logdir:		Directory to store Kafka logs
+#			Default: %%KAFKA_LOGDIR%%
+# kafka_jvmopts:	Options passed to JVM to start Kafka
+#			Default: None
+# kafka_pidfile:	Full path of the Kafka process PID file
+#			Default: %%KAFKA_RUNDIR%%/kafka.pid
+# kafka_outfile:	File to store Kafka's stdout and stderr
+#			Default: $kafka_logdir/kafkaServer.out
+
+. /etc/rc.subr
+
+name=kafka
+rcvar=kafka_enable
+
+load_rc_config "${name}"
+
+: ${kafka_enable:=NO}
+: ${kafka_user:=%%USERS%%}
+: ${kafka_group:=%%GROUPS%%}
+: ${kafka_config:=%%ETCDIR%%/server.properties}
+: ${kafka_log4jpropfile:=%%ETCDIR%%/log4j.properties}
+: ${kafka_logdir:=%%KAFKA_LOGDIR%%}
+: ${kafka_jvmopts:=}
+: ${kafka_outfile:=$kafka_logdir/kafkaServer.out}
+: ${kafka_pidfile:=%%KAFKA_RUNDIR%%/kafka.pid}
+
+JAVA=%%JAVA%%
+
+CLASSPATH=":%%DATADIR%%/libs/*"
+
+kafka_logopts="-Dkafka.logs.dir=${kafka_logdir} -Dlog4j.configuration=file:${kafka_log4jpropfile}"
+kafka_main="$kafka_jvmopts $kafka_logopts -cp $CLASSPATH"
+pidfile=${kafka_pidfile}
+procname=${JAVA}
+required_files="${kafka_config} ${kafka_log4jpropfile}"
+
+daemon_head=""
+daemon_tail=" > $kafka_outfile 2>&1 < /dev/null"
+
+if [ -z $kafka_outfile ]; then
+	daemon_head="-f"
+	daemon_tail=""
+fi
+
+command="/usr/sbin/daemon"
+command_args="${daemon_head} -p ${pidfile} ${JAVA} ${kafka_main} kafka.Kafka ${kafka_config} ${daemon_tail}"
+
+start_precmd="kafka_init"
+
+kafka_init()
+{
+	chown ${kafka_user}:${kafka_group} ${pidfile%/*} ${kafka_logdir} ${kafka_outfile}
+}
+
+run_rc_command "$1"
diff --git a/net/kafka/files/patch-bin_kafka-run-class.sh b/net/kafka/files/patch-bin_kafka-run-class.sh
new file mode 100644
index 000000000000..a0d2cc8ed9dd
--- /dev/null
+++ b/net/kafka/files/patch-bin_kafka-run-class.sh
@@ -0,0 +1,16 @@
+--- bin/kafka-run-class.sh.orig	2017-07-14 16:36:53 UTC
++++ bin/kafka-run-class.sh
+@@ -125,12 +125,7 @@ do
+ done
+ 
+ # classpath addition for release
+-for file in "$base_dir"/libs/*;
+-do
+-  if should_include_file "$file"; then
+-    CLASSPATH="$CLASSPATH":"$file"
+-  fi
+-done
++CLASSPATH="$CLASSPATH":"$base_dir"/libs/*
+ 
+ for file in "$base_dir"/core/build/libs/kafka_${SCALA_BINARY_VERSION}*.jar;
+ do