kafka启动小脚本

#!/bin/bash

Kafka安装路径

KAFKA_HOME=“/home/kafka_2.11”

Kafka启动脚本路径

KAFKA_START_SCRIPT=“$KAFKA_HOME/bin/kafka-server-start.sh”

Kafka配置文件路径

KAFKA_CONFIG_FILE=“$KAFKA_HOME/config/server.properties”

日志文件路径

LOG_FILE=“$KAFKA_HOME/kafka_startup.log”

定义一个函数 打印带时间戳的日志消息

function log_message {
echo “$(date ‘+%Y-%m-%d %H:%M:%S’) $1">>"$LOG_FILE”
}

检查Kafka进程是否已经在运行

PID=$(pgrep -f kafka_2.11)

if [ -z “$PID” ]; then
log_message “Kafka进程未运行，尝试启动…”
# 尝试启动Kafka，并将输出重定向到日志文件
source /etc/profile && sh $KAFKA_START_SCRIPT -daemon $KAFK{A}_{C}ONFI{G}_{F}ILE>>"$LOG_FILE" 2>&1

# 检查Kafka启动命令的退出状态  
if [ $? -eq 0 ]; then  log_message "Kafka启动成功。"  
else  log_message "Kafka启动失败，请查看日志文件以获取更多信息 "  
fi  

fi