启动zookeeper集群

zkServer.sh start

查看状态

zkServer.sh status

在虚拟机外部创建脚本start-kafka.sh

添加权限chmod +x ./start-kafka.sh

具体配置文件如下

#!/bin/bash
if [ $# -lt 1 ]
then 
  echo "Input Args Error....."
  exit
fi
for i in 192.168.74.139 192.168.74.128 192.168.74.140
do

case $1 in
start)
  echo "==================START $i KAFKA==================="
  ssh $i /opt/apps/kafka/bin/kafka-server-start.sh -daemon   /opt/apps/kafka/config/server.properties
;;
stop)
  echo "==================STOP $i KAFKA==================="
  ssh $i /opt/apps/kafka/bin/kafka-server-stop.sh stop
;;

*)
 echo "Input Args Error....."
 exit
;;  
esac

done

需要修改每个虚拟机的IP地址

路径需要修改

在这里小编就不做具体改变了

之后./start-kafka.sh start即可启动三台虚拟机的集群

解决错误: 

[root@bogon kafka]# rm -rf logs/
[root@bogon kafka]# mkdir logs
[root@bogon kafka]# nohup bin/kafka-server-start.sh config/server.properties &
[1] 16021
[root@bogon kafka]# nohup: 忽略输入并把输出追加到'nohup.out'
[root@bogon kafka]# jps
26694 Kafka
9978 QuorumPeerMain
27119 Jps

上述只需删除文件夹logs即可

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐