kafka-server-start脚本简介

kafka-server-start脚本通过kafka-run-class脚本调用Kafka类来启动Broker,在调用kafka-run-class脚本之前会进行检测命令行参数、设置log4j配置文件、设置JVM内存参数等操作。

#!/bin/bash

if [$# -lt 1]; #检查参数个数

then #打印命令用法

echo "USAGE: $0 [-daemon] server.properties [--override property-value]*"

exit 1

fi

base_ dir=$(dirname $0) #获取当前脚本所在的路径

#设置Log4j相关的环境变量

if [ "x$KAFKA_LOG4J_OPTS" = "x" ]; then

export KAFKA_LOG4J_OPTS =

"-Dlog4j.configuration=file:$base_dir/../config/log4f.properties"

fi

#设置JVM的内存

if[ "x$KAFKA_HEAP_OPTS" = "x"]; then

export KAEKA_HEAP_OPTS="-Xmx1G -Xms1G"

fi

EXTRA ARGS-"-name kafkaServer -1oggc"

#检测第一个参数是否为"-daemon"

COMMAND=$1

case SCOMMAND in

-daemon)

EXTRA_ARGS="-daemon "SEXTRA ARGS

shift # 左移参数列表，即删除"-daemon"参数

# 调用kafka-run-class 脚本

exec $base_dir/kafka-run-class.sh $EXTRA_ARGS kafka.Kafka "$@"

很多脚本和工具类都依赖于kafka-run-class脚本，其中的主要功能是设置CLASSPATH,进行JMX的相关配置，配置Log4j，指定存放日志文件和索引文件位置，检测JAVA HOME环境变量，进行JVM的相关配置，决定是否后台启动。