linux安装Kafka3.0.0

wget https://archive.apache.org/dist/kafka/3.0.0/kafka_2.12-3.0.0.tgz
修改配置
chown -R hadoop:hadoop /opt/data/kafka

server.properties
>>
broker.id=0 1 2
log.dirs=/opt/data/kafka/data
zookeeper.connect=master:2181,node1:2181,node2:2181/kafka
<<
vim /etc/profile
>>
export KAFKA_HOME=/home/hadoop/opt/kafka
export PATH=$PATH:$KAFKA_HOME/bin
<<
#启动卡夫卡 先启动zookeeper
kafka-server-start.sh -daemon /home/hadoop/opt/kafka/config/server.properties
#编写脚本启动 kafka.sh
>>
#!/bin/bash

case $1 in 
"start")
	for i in master node1 node2
	do
		echo "---------启动$i kafka ---"
		ssh $i "/home/hadoop/opt/kafka/bin/kafka-server-start.sh -daemon /home/hadoop/opt/kafka/config/server.properties"
	done
;;
"stop")
	for i in master node1 node2
        do
                echo "---------停止$i kafka ---"
                ssh $i "/home/hadoop/opt/kafka/bin/kafka-server-stop.sh"
        done

;;
esac
<<