Kafka系列-1、kafka环境搭建

版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。

大数据系列文章目录

kafka的中文网站

搭建Kafka集群

1、将Kafka的安装包上传到虚拟机，并解压

cd /export/software/
tar -xvzf kafka_2.12-2.4.1.tgz -C ../server/
cd /export/server/kafka_2.12-2.4.1/
1
2
3

2、修改 server.properties

cd /export/server/kafka_2.12-2.4.1/config
vim server.properties
# 指定broker的id
broker.id=0
# 指定 kafka的绑定监听的地址
listeners=PLAINTEXT://node1:9092
# 指定Kafka数据的位置
log.dirs=/export/server/kafka_2.12-2.4.1/data
# 配置zk的三个节点
zookeeper.connect=node:2181,node2:2181,node3:2181
1
2
3
4
5
6
7
8
9
10

3、将安装好的kafka复制到另外两台服务器

cd /export/server
scp -r kafka_2.12-2.4.1/ node2:$PWD
scp -r kafka_2.12-2.4.1/ node3:$PWD

修改另外两个节点的broker.id分别为1和2
---------node2--------------
cd /export/server/kafka_2.12-2.4.1/config
vim erver.properties
broker.id=1
listeners=PLAINTEXT://node2:9092

--------node3--------------
cd /export/server/kafka_2.12-2.4.1/config
vim server.properties
broker.id=2
listeners=PLAINTEXT://node3:9092
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

4、配置KAFKA_HOME环境变量

vim /etc/profile
export KAFKA_HOME=/export/server/kafka_2.12-2.4.1
export PATH=:$PATH:${KAFKA_HOME}

分发到各个节点
scp /etc/profile node2:$PWD
scp /etc/profile node3:$PWD
每个节点加载环境变量
source /etc/profile
1
2
3
4
5
6
7
8
9

5、启动服务器

# 启动ZooKeeper
nohup bin/zookeeper-server-start.sh config/zookeeper.properties &
# 启动Kafka
cd /export/server/kafka_2.12-2.4.1
nohup bin/kafka-server-start.sh config/server.properties 2>&1 &
# 测试Kafka集群是否启动成功 : 
使用 jps 查看各个节点 是否出现有kafka
1
2
3
4
5
6
7

或者通过 zookeeper查看 brokers节点目录下, 是否有三个ids

目录结构分析

kafka一键启动/关闭脚本

为了方便将来进行一键启动、关闭Kafka，我们可以编写一个shell脚本来操作。将来只要执行一次该脚本就可以快速启动/关闭Kafka。

1、在节点1中创建 /export/onekey 目录

cd /export/onekey
1

2、 准备slave配置文件，用于保存要启动哪几个节点上的kafka

node1
node2
node3
1
2
3

3、编写kafka.sh脚本

#!/bin/bash

echo "zk集群一键启动、停止、重启、查询状态脚本。。。。"
command_array=("一键启动" "一键停止" "查询状态" "一键重启")

operateFun(){
     for var in node1 node2 node3
     do
        ssh $var "source /etc/profile; zkServer.sh $1"
     done
}

PS3="请输入对应编号，会执行zookeeper集群的相应命令："
select var in ${command_array[*]}
do
 case $var in
      "一键启动")
      operateFun start
      ;;
      "一键停止")
      operateFun stop
      ;;
      "查询状态")
      operateFun status
      ;;
      "一键重启")
      operateFun restart
      ;;
      *)
       echo "编号错误！"
      ;;
 esac
 exit
done
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

4、给kafka.sh配置执行权限

chmod u+x kafka.sh
1