1.启动kafka集群
kafka 没有提供同时启动集群中所有节点的执行脚本,这里自定义一个脚本
名称为 kafka-cluster-start.sh
2.关闭节点
kafka自带关闭脚本
kafka-server-stop.sh
如不能关闭,输出信息如下
No kafka server to stop
这是因为在某些系统中,脚本的命令无法获取kafka的pid,
ps ax | grep -i 'kafka\.kafka' |grep java |grep -v grep |awk '{print $1}'
因此,这里需要将关闭脚本中查找pid的命令修改如下:
PID=$(jps | grep -i 'Kafka' | awk '{print $1}')