标签：bin opt module kafka sh 集群 HOME KAFKA 搭建

一、下载及安装

1.地址

https://www.apache.org/dyn/closer.cgi?path=/kafka/3.1.0/kafka_2.12-3.1.0.tgz

2.上传到linux解压: 

tar -zxvf kafka_2.12-3.1.0.tgz -C /opt/module/

3.进入kafka的配置目录：

cd config/

4.修改配置文件：

vi server.properties

注：beoker.id是kafka的唯一标识

log.dirs是kafka日志存储路径

zookeeper.connect改为集群，放到kafka目录下是为了便于管理

 

每台服务器除了broker.id不同，其他一致

二、配置jdk及kafka的环境变量

1.修改配置

#进入目录
cd /etc/profile.d/
#新建文件
vim my_env.sh

#JAVA_HOME
export JAVA_HOME=/opt/module/jdk
export PATH=$PATH:$JAVA_HOME/bin

#KAFKA_HOME
export KAFKA_HOME=/opt/module/kafka
export PATH=$PATH:$KAFKA_HOME/bin

2.刷新配置

source /etc/profile
#是配置立即生效并检查jdk版本
java -version

3.在home目录下创建bin，在bin下创建kf.sh文件并修改权限

vim kf.sh
chmod 777 kf.sh 

#!/bin/bash

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

4.生成公钥私钥

#在要使用脚本的机器上执行
ssh-keygen -t rsa
#执行(即每台服务器都执行一次)
ssh-copy-id -i ~/.ssh/id_rsa.pub root@主机名或者ip

5.启动

./kf.sh start

 

未完待续。。

 

标签：bin,opt,module,kafka,sh,集群,HOME,KAFKA,搭建
From： https://www.cnblogs.com/walden-g/p/17105423.html