#! /bin/bash if [ $# -lt 1 ] then echo "Usage: kf.sh {start|stop|kc [topic]|kp [topic] |list |delete [topic] |describe [topic]}" exit fi case $1 in "start") for i in sgghadoop102 sgghadoop103 sgghadoop104 do echo "============> Start $i Kafka <============" ssh $i "/opt/module/kafka_2.11-2.4.1/bin/kafka-server-start.sh -daemon /opt/module/kafka_2.11-2.4.1/config/server.properties" done ;; "stop") for i in sgghadoop102 sgghadoop103 sgghadoop104 do echo "============> Stop $i Kafka <============" ssh $i "/opt/module/kafka_2.11-2.4.1/bin/kafka-server-stop.sh stop" done ;; "kc") if [ $2 ] then kafka-console-consumer.sh --bootstrap-server sgghadoop102:9092,sgghadoop103:9092,sgghadoop104:9092 --topic $2 else echo "Usage: kf.sh {start|stop|kc [topic]|kp [topic] |list |delete [topic] |describe [topic]}" fi ;;

这段代码是一个 Bash 脚本，用于启动、停止、查看 Kafka 集群中的 topic 等操作。其中，start 命令会通过 ssh 命令在 sgghadoop102、sgghadoop103 和 sgghadoop104 上启动 Kafka 服务；stop 命令会在这三个节点上停止 Kafka 服务；kc 命令用于查看指定 topic 的消息，需要指定 topic 名称作为第二个参数。另外，脚本还提供了 kp、list、delete 和 describe 命令，分别用于生产消息、查看 topic 列表、删除 topic 和查看 topic 的详细信息。需要注意的是，这个脚本需要在安装了 Kafka 的服务器上执行，并且需要按照实际情况修改脚本中的节点名称和 Kafka 安装路径。