kafka-server 启动脚本分享
[code]#!/bin/bash
#
# /etc/init.d/kafka-server
#
# Startup script for kafka-server
#
# chkconfig: 2345 20 80
# description: Starts and stops kafka-server
. /etc/init.d/functions
desc="Kafka distributed messaging system"
if [ -f /etc/sysconfig/kafka ]; then
. /etc/sysconfig/kafka
fi
start() {
echo "Starting $desc (kafka-server): "
for file in $KAFKA_HOME/project/boot/scala-2.8.0/lib/*.jar; do
CLASSPATH=$CLASSPATH:$file
done
for file in $KAFKA_HOME/core/target/scala_2.8.0/*.jar;do
CLASSPATH=$CLASSPATH:$file
done
for file in $KAFKA_HOME/core/lib/*.jar;do
CLASSPATH=$CLASSPATH:$file
done
for file in $KAFKA_HOME/core/lib_managed/scala_2.8.0/compile/*.jar; do
if [ ${file##*/} != "sbt-launch.jar" ]; then
CLASSPATH=$CLASSPATH:$file
fi
done
if [ -z "$JAVA_OPTS" ]; then
JAVA_OPTS="-Xmx512M -server -Dlog4j.configuration=file:$KAFKA_CONF/log4j.properties"
fi
if [ -z "$JAVA_HOME" ]; then
JAVA="java"
else
JAVA="$JAVA_HOME/bin/java"
fi
su $KAFKA_USER -c "nohup $JAVA $JAVA_OPTS -cp $CLASSPATH kafka.Kafka $KAFKA_CONF/server.properties >>$KAFKA_OUT 2>&1 &"
RETVAL=$?
return $RETVAL
}
stop() {
echo "Shutting down $desc (kafka-server): "
pkill -f kafka.Kafka
}
restart() {
stop
start
}
status() {
pid=$(pgrep -f kafka.Kafka)
if [ -z $pid ]; then
echo "kafka-server is NOT running."
else
echo "kafka-server is running (pid is $pid)."
fi
}
case "$1" in
start) start;;
stop) stop;;
restart) restart;;
status) status;;
*) echo "Usage: $0 {start|stop|restart}"
RETVAL=2;;
esac
exit $RETVAL[/code]
没有找到相关结果
已邀请:
0 个回复