|
Lines 11-18
Link Here
|
| 11 |
# |
11 |
# |
| 12 |
# kafka_user: Username to run Kafka |
12 |
# kafka_user: Username to run Kafka |
| 13 |
# Default: %%USERS%% |
13 |
# Default: %%USERS%% |
| 14 |
# kafka_group: Groupname to run Kafka |
|
|
| 15 |
# Default: %%GROUPS%% |
| 16 |
# kafka_config: Configuration file to run Kafka |
14 |
# kafka_config: Configuration file to run Kafka |
| 17 |
# Default: %%ETCDIR%%/server.properties |
15 |
# Default: %%ETCDIR%%/server.properties |
| 18 |
# kafka_log4j_profile: Profile for Kafka logging |
16 |
# kafka_log4j_profile: Profile for Kafka logging |
|
Lines 21-27
Link Here
|
| 21 |
# Default: %%KAFKA_LOGDIR%% |
19 |
# Default: %%KAFKA_LOGDIR%% |
| 22 |
# kafka_java_opts: Options passed to JVM to start Kafka |
20 |
# kafka_java_opts: Options passed to JVM to start Kafka |
| 23 |
# Default: None |
21 |
# Default: None |
| 24 |
# kafka_pid_file: Full path of the Kafka process PID file |
22 |
# kafka_pidfile: Full path of the Kafka process PID file |
| 25 |
# Default: %%KAFKA_RUNDIR%%/kafka.pid |
23 |
# Default: %%KAFKA_RUNDIR%%/kafka.pid |
| 26 |
# kafka_syslog_output_enable: Set to enable syslog output. |
24 |
# kafka_syslog_output_enable: Set to enable syslog output. |
| 27 |
# Default: YES |
25 |
# Default: YES |
|
Lines 39-54
Link Here
|
| 39 |
|
37 |
|
| 40 |
: ${kafka_enable:=NO} |
38 |
: ${kafka_enable:=NO} |
| 41 |
: ${kafka_user:=%%USERS%%} |
39 |
: ${kafka_user:=%%USERS%%} |
| 42 |
: ${kafka_group:=%%GROUPS%%} |
|
|
| 43 |
: ${kafka_config:=%%ETCDIR%%/server.properties} |
40 |
: ${kafka_config:=%%ETCDIR%%/server.properties} |
| 44 |
: ${kafka_log4j_profile:=%%ETCDIR%%/log4j.properties} |
41 |
: ${kafka_log4j_profile:=%%ETCDIR%%/log4j.properties} |
| 45 |
: ${kafka_log_dir:=%%KAFKA_LOGDIR%%} |
42 |
: ${kafka_log_dir:=%%KAFKA_LOGDIR%%} |
| 46 |
: ${kafka_java_opts:=} |
43 |
: ${kafka_java_opts:=} |
| 47 |
: ${kafka_pid_file:=%%KAFKA_RUNDIR%%/kafka.pid} |
44 |
: ${kafka_pidfile:=%%KAFKA_RUNDIR%%/kafka.pid} |
| 48 |
: ${kafka_syslog_output_enable:="YES"} |
45 |
: ${kafka_syslog_output_enable:="YES"} |
| 49 |
|
46 |
|
| 50 |
if checkyesno kafka_syslog_output_enable; then |
47 |
if checkyesno kafka_syslog_output_enable; then |
| 51 |
kafka_syslog_output_flags="-t ${name} -T ${name}" |
48 |
kafka_syslog_output_flags="-T ${name}" |
| 52 |
if [ -n "${kafka_syslog_output_priority}" ]; then |
49 |
if [ -n "${kafka_syslog_output_priority}" ]; then |
| 53 |
kafka_syslog_output_flags="${kafka_syslog_output_flags} -s ${kafka_syslog_output_priority}" |
50 |
kafka_syslog_output_flags="${kafka_syslog_output_flags} -s ${kafka_syslog_output_priority}" |
| 54 |
fi |
51 |
fi |
|
Lines 62-83
Link Here
|
| 62 |
CLASSPATH=":%%DATADIR%%/libs/*" |
59 |
CLASSPATH=":%%DATADIR%%/libs/*" |
| 63 |
|
60 |
|
| 64 |
kafka_log_opts="-Dkafka.logs.dir=${kafka_log_dir} -Dlog4j.configuration=file:${kafka_log4j_profile}" |
61 |
kafka_log_opts="-Dkafka.logs.dir=${kafka_log_dir} -Dlog4j.configuration=file:${kafka_log4j_profile}" |
| 65 |
kafka_main="$kafka_java_opts $kafka_log_opts -cp $CLASSPATH" |
62 |
kafka_main="${kafka_java_opts} ${kafka_log_opts} -cp $CLASSPATH kafka.Kafka ${kafka_config}" |
| 66 |
pidfile=${kafka_pid_file} |
63 |
pidfile="${kafka_pidfile}" |
| 67 |
procname=${JAVA} |
64 |
required_dirs="${kafka_log_dir}" |
| 68 |
required_files="${kafka_config} ${kafka_log4j_profile}" |
65 |
required_files="${kafka_config} ${kafka_log4j_profile}" |
| 69 |
|
66 |
|
| 70 |
|
|
|
| 71 |
command="/usr/sbin/daemon" |
67 |
command="/usr/sbin/daemon" |
| 72 |
command_args="-f ${kafka_syslog_output_flags} -p ${pidfile} ${JAVA} ${kafka_main} kafka.Kafka ${kafka_config}" |
68 |
command_args="-f ${kafka_syslog_output_flags} -P ${pidfile} -u ${kafka_user} -t ${name} ${JAVA} ${kafka_main}" |
|
|
69 |
unset kafka_user |
| 73 |
|
70 |
|
| 74 |
start_precmd="kafka_init" |
|
|
| 75 |
|
| 76 |
|
| 77 |
kafka_init() |
| 78 |
{ |
| 79 |
[ -d "$kafka_log_dir" ] || mkdir -p "$kafka_log_dir" |
| 80 |
chown ${kafka_user}:${kafka_group} ${pidfile%/*} ${kafka_log_dir} ${kafka_config} ${kafka_log4j_profile} |
| 81 |
} |
| 82 |
|
| 83 |
run_rc_command "$1" |
71 |
run_rc_command "$1" |