Lines 2-8
Link Here
|
2 |
# $FreeBSD$ |
2 |
# $FreeBSD$ |
3 |
# |
3 |
# |
4 |
# PROVIDE: kafka_connect |
4 |
# PROVIDE: kafka_connect |
5 |
# REQUIRE: LOGIN |
5 |
# REQUIRE: NETWORKING SERVERS DAEMON |
6 |
# KEYWORD: shutdown |
6 |
# KEYWORD: shutdown |
7 |
# |
7 |
# |
8 |
# Add kafka_connect_enable="YES" to /etc/rc.conf to enable Kafka Connect: |
8 |
# Add kafka_connect_enable="YES" to /etc/rc.conf to enable Kafka Connect: |
Lines 11-16
Link Here
|
11 |
# |
11 |
# |
12 |
# kafka_connect_user: Username to run Kafka Connect |
12 |
# kafka_connect_user: Username to run Kafka Connect |
13 |
# Default: %%KAFKA_USER%% |
13 |
# Default: %%KAFKA_USER%% |
|
|
14 |
# kafka_connect_group: Group to run Kafka Connect |
15 |
# Default: %%KAFKA_GROUP%% |
14 |
# kafka_connect_config: Configuration file to run Kafka Connect |
16 |
# kafka_connect_config: Configuration file to run Kafka Connect |
15 |
# Default: %%ETCDIR%%/connect.properties |
17 |
# Default: %%ETCDIR%%/connect.properties |
16 |
# kafka_connect_log4j_config: Configuration file for Kafka Connect logging |
18 |
# kafka_connect_log4j_config: Configuration file for Kafka Connect logging |
Lines 19-28
Link Here
|
19 |
# Default: %%KAFKA_LOGDIR%% |
21 |
# Default: %%KAFKA_LOGDIR%% |
20 |
# kafka_connect_java_opts: Options passed to JVM to start Kafka Connect |
22 |
# kafka_connect_java_opts: Options passed to JVM to start Kafka Connect |
21 |
# Default: None |
23 |
# Default: None |
22 |
# kafka_connect_pidfile: Full path of the Kafka process PID file |
24 |
# kafka_connect_pidfile: Full path of the Kafka Connect process PID file |
23 |
# Default: /var/run/kafka_connect.pid |
25 |
# Default: /var/run/kafka_connect.pid |
24 |
# kafka_connect_syslog_output_enable: Set to enable syslog output. |
26 |
# kafka_connect_syslog_output_enable: Set to enable syslog output. |
25 |
# Default: YES |
27 |
# Default: YES |
|
|
28 |
# kafka_connect_syslog_output_tag: Set syslog tag if syslog enabled. |
29 |
# Default: kafka_connect |
26 |
# kafka_connect_syslog_output_priority: Set syslog priority if syslog enabled. |
30 |
# kafka_connect_syslog_output_priority: Set syslog priority if syslog enabled. |
27 |
# Default: info |
31 |
# Default: info |
28 |
# kafka_connect_syslog_output_facility: Set syslog facility if syslog enabled. |
32 |
# kafka_connect_syslog_output_facility: Set syslog facility if syslog enabled. |
Lines 35-56
Link Here
|
35 |
|
39 |
|
36 |
load_rc_config "${name}" |
40 |
load_rc_config "${name}" |
37 |
|
41 |
|
38 |
: ${kafka_connect_enable:=NO} |
42 |
: ${kafka_connect_enable:="NO"} |
39 |
: ${kafka_connect_user:=%%KAFKA_USER%%} |
43 |
: ${kafka_connect_user:="%%KAFKA_USER%%"} |
40 |
: ${kafka_connect_config:=%%ETCDIR%%/connect.properties} |
44 |
: ${kafka_connect_group:="%%KAFKA_GROUP%%"} |
41 |
: ${kafka_connect_log4j_config:=%%ETCDIR%%/connect-log4j.properties} |
45 |
: ${kafka_connect_config:="%%ETCDIR%%/connect.properties"} |
42 |
: ${kafka_connect_log_dir:=%%KAFKA_LOGDIR%%} |
46 |
: ${kafka_connect_log4j_config:="%%ETCDIR%%/connect-log4j.properties"} |
|
|
47 |
: ${kafka_connect_log_dir:="%%KAFKA_LOGDIR%%"} |
43 |
: ${kafka_connect_pidfile:=/var/run/kafka_connect.pid} |
48 |
: ${kafka_connect_pidfile:=/var/run/kafka_connect.pid} |
44 |
: ${kafka_connect_syslog_output_enable:="YES"} |
49 |
: ${kafka_connect_syslog_output_enable:="YES"} |
45 |
: ${kafka_connect_standalone:="YES"} |
50 |
: ${kafka_connect_standalone:="YES"} |
46 |
|
51 |
|
47 |
_kafka_connect_user=${kafka_connect_user} |
52 |
start_precmd="kafka_connect_start_precmd" |
48 |
unset kafka_connect_user |
|
|
49 |
|
53 |
|
50 |
kafka_connect_log4j_config="${kafka_connect_log4j_profile#file:}" |
|
|
51 |
|
52 |
if checkyesno kafka_connect_syslog_output_enable; then |
54 |
if checkyesno kafka_connect_syslog_output_enable; then |
53 |
kafka_connect_syslog_output_flags="-T ${name}" |
55 |
if [ -n "${kafka_syslog_output_tag}" ]; then |
|
|
56 |
kafka_connect_syslog_output_flags="-T ${kafka_connect_syslog_output_tag}" |
57 |
else |
58 |
kafka_connect_syslog_output_flags="-T ${name}" |
59 |
fi |
54 |
if [ -n "${kafka_connect_syslog_output_priority}" ]; then |
60 |
if [ -n "${kafka_connect_syslog_output_priority}" ]; then |
55 |
kafka_connect_syslog_output_flags="${kafka_connect_syslog_output_flags} -s ${kafka_connect_syslog_output_priority}" |
61 |
kafka_connect_syslog_output_flags="${kafka_connect_syslog_output_flags} -s ${kafka_connect_syslog_output_priority}" |
56 |
fi |
62 |
fi |
Lines 75-80
Link Here
|
75 |
required_files="${kafka_connect_config} ${kafka_connect_log4j_config}" |
81 |
required_files="${kafka_connect_config} ${kafka_connect_log4j_config}" |
76 |
|
82 |
|
77 |
command="/usr/sbin/daemon" |
83 |
command="/usr/sbin/daemon" |
78 |
command_args="-f ${kafka_connect_syslog_output_flags} -P ${pidfile} -u ${_kafka_connect_user} -t ${name} ${JAVA} ${kafka_connect_main}" |
84 |
command_args="-f ${kafka_connect_syslog_output_flags} -P ${pidfile} -t ${name} ${JAVA} ${kafka_connect_main}" |
79 |
|
85 |
|
|
|
86 |
kafka_connect_start_precmd() |
87 |
{ |
88 |
if [ ! -e "${pidfile}" ]; then |
89 |
install -m 0600 -o "${kafka_connect_user}" -g "${kafka_connect_group}" /dev/null "${pidfile}" |
90 |
fi |
91 |
} |
92 |
|
80 |
run_rc_command "$1" |
93 |
run_rc_command "$1" |