Kafka02:Kafka集群部署

1.环境准备

1）集群规划

slave1	slave2	slave3
zk	zk	zk
kafka	kafka	kafka

2）jar 包下载
http://kafka.apache.org/downloads.html

2.Kafka 集群部署

1）解压安装包
[root@slave1 src]# tar -zxvf kafka_2.11-0.10.2.1.tgz
2）修改解压后的文件名称
[root@slave1 src]# mv kafka_2.11-0.10.2.1/ kafka
3）在/usr/local/src/kafka 目录下创建 logs 文件夹
[root@slave1 src]# mkdir logs
4）修改配置文件
[root@slave1 kafka]# cd config/
[root@slave1 config]# vi server.properties
输入以下内容：

5）配置环境变量
KAFKA_HOME=/usr/local/src/kafka_2.11-0.10.2.1
export KAFKA_HOME
PATH=$KAFKA_HOME/bin:$PATH
export PATH
6）分发安装包
注意：分发之后记得配置其他机器的环境变量
7）分别在 slave2和 slave3上修改配置文件server.properties 中的 broker.id=1、broker.id=2
注：broker.id 不得重复
8）启动集群
依次在 slave1、slave2、slave3节点上启动 kafka
[root@slave1 kafka]# bin/kafka-server-start.sh config/server.properties &
[root@slave2 kafka]# bin/kafka-server-start.sh config/server.properties &
[root@slave3 kafka]# bin/kafka-server-start.sh config/server.properties &

9）关闭集群
[root@slave1 kafka]# bin/kafka-server-stop.sh config/server.properties &
[root@slave2 kafka]# bin/kafka-server-stop.sh config/server.properties &
[root@slave3 kafka]# bin/kafka-server-stop.sh config/server.properties &