kafka集群启动和停止脚本

Apache Kafka是一个分布式流处理平台，用于构建实时数据管道和流应用。为了管理和操作Kafka集群，通常会编写启动和停止脚本来自动化这个过程。以下是创建Kafka集群启动和停止脚本的一些基本步骤：

**启动脚本(Kafka启动.sh)**:

1. **检查环境**: 确保所有依赖已安装，如Zookeeper、JDK等。
2. **设置环境变量**: 配置Kafka_HOME指向安装目录，设置其他环境变量如KAFKA_OPTS（例如内存限制）。
3. **启动服务**: 使用`bin/kafka-server-start.sh`命令启动Kafka broker节点，可以指定配置文件路径。
4. **日志监控**: 可能还需要添加对日志文件和进程状态的检查。

**停止脚本(Kafka停止.sh)**:

1. **停止服务**: 使用`bin/kafka-server-stop.sh`命令优雅地关闭broker节点。
2. **确认停止**: 检查Kafka是否完全停止，包括清理网络连接和停止后台线程。
3. **清理资源**: 如果有持久化数据，确保它们已经妥善清理。

**例子脚本片段**（假设脚本名为kafka_start_stop.sh）:

#!/bin/bash

# 启动
start_kafka() {
  if [ ! -d "$KAFKA_HOME/logs" ]; then
    mkdir -p $KAFKA_HOME/logs
  fi
  export KAFKA_OPTS="-Dlog.dirs=$KAFKA_HOME/logs"
  echo "Starting Kafka..."
  bin/kafka-server-start.sh ${KAFKA_CONFIG_DIR}/server.properties &
  sleep 5  # 等待服务器启动完成
}

# 停止
stop_kafka() {
  echo "Stopping Kafka..."
  kill $(ps aux | grep kafka-server-start | awk '{print $2}')
  wait
  echo "Kafka stopped."
}

# 脚本控制
case "$1" in
  start)
    start_kafka
    ;;
  stop)
    stop_kafka
    ;;
  *)
    echo "Usage: ./kafka_start_stop.sh {start|stop}"
    exit 1
    ;;
esac