kafka的安装

tar -zxf kafka_2.12-2.6.2.tgz  -C /usr/

改名字

cd /usr/
mv kafka_2.12-2.6.2/ kafka

cd /usr/kafka/config/

vi server.properties

在broker.id=0下面
写入

zookeeper.connect=slave1:2181,slave2:2181
log.dirs=/usr/local/logs/kafka-logs

环境变量

vi /etc/profile

#kafka
export KAFKA_HOME=/usr//kafka
export PATH=$PATH:$KAFKA_HOME/bin

source /etc/profile

kafka

scp -r /usr/kafka slave1:/usr/
scp -r /usr/kafka slave2:/usr/

分别修改 broker.id 为 1 跟 2

环境变量

scp /etc/profile slave1:/etc
scp /etc/profile slave2:/etc

source /etc/profile

各节点启动 zookeeper 后，再启动 kafka

 zkServer.sh start

kafka-server-start.sh -daemon /usr/kafka/config/server.properties &

jps

出现kafka