安装和监控

参考：https://kafka.apache.org/quickstart

启动脚本start.sh

Kafka根目标新建启动脚本start.sh，通过chmod +x start.sh增加执行权限。

  1. #! /bin/bash
  2. echo "starting zookeeper..."
  3. rm -rf zookeeper.out
  4. # 以后台不挂断的方式启动zookeeper，标准输出重定向到文件zookeeper.out
  5. nohup bin/zookeeper-server-start.sh config/zookeeper.properties >zookeeper.out &
  6. sleep 1
  7. while ! grep -m1 'PrepRequestProcessor (sid:0) started' < zookeeper.out; do
  8.     sleep 1
  9. done
  10. echo "zookeeper started."
  12. echo "starting kafka..."
  13. rm -rf kafka.out
  14. # 开启Kafka jmx，使得Kafka监控程序可以获得Kafka详细的运行数据
  15. export JMX_PORT=5551
  16. # 以后台不挂断的方式启动kafka，标准输出重定向到文件kafka.out
  17. nohup bin/kafka-server-start.sh config/server.properties >kafka.out &

停止脚本stop.sh

Kafka根目标新建启动脚本stop.sh，通过chmod +x stop.sh增加执行权限。

  1. echo "stopping kafka..."
  2. bin/kafka-server-stop.sh
  3. sleep 1
  4. while ! grep -m1 'shut down completed' < kafka.out; do
  5.     sleep 1
  6. done
  7. echo "kafka stopped."
  9. echo "stopping zookeeper..."
  10. bin/zookeeper-server-stop.sh

Kafka监控CMAK

CMAK(Kafka Manager)：https://github.com/yahoo/CMAK

CMAK监控说明：https://www.huaweicloud.com/articles/9e5a449e77b025c064b4f22cf0f18c50.html

CMAK根目录新建启动脚本start.sh，通过chmod +x start.sh增加执行权限。

  1. # 指定zookeeper地址
  2. export ZK_HOSTS="localhost:2181"
  3. # 以后台不挂断的方式启动cmak，并指定JAVA_HOME，假设jdk11安装在/usr/java/jdk-11
  4. nohup /usr/local/cmak-3.0.0.5/bin/cmak -java-home /usr/java/jdk-11/ >cmak.out &