kafka的安装

一、安装zookeeper

安装kafka必须先安装zookeeper，由于kafka自带有zookeeper，可以选择性安装第三方的zookeeper，建议安装第三方的zookeeper

zookeeper的搭建和简单的使用

二、下载并解压kafka安装包到三台服务器上

三、分别修改三台服务器配置文件

1.修改server.properties

## broker的全局唯一编号，不能重复
broker.id=0
## 服务器需要监听的端口号
listeners=PLAINTEXT://master: 
## 注册到zookeeper的IP和端口
advertised.listeners=PLAINTEXT://master:9092
## 存储消息的目录
log.dirs=/opt/apply/kafka_2.12-2.5.1/kafka-logs
## 连接的zookeeper
zookeeper.connect=master:2181,slaver1:2181,slaver1:2181

项	说明
broker.id	三个节点分别设置为 0、1、2
listeners	PLAINTEXT://slaver1:9092，根据当前机器的IP设置
advertised.listeners	PLAINTEXT://slaver1:9092，根据当前机器的IP设置

2.修改producer.properties

## 指定kafka节点列表，用于获取metadata，不必配置全部
bootstrap.servers=master:9092,slaver1:9092,slaver2:9092

3.修改consumer.properties

## 指定kafka节点列表，用于获取metadata，不必配置全部
bootstrap.servers=master:9092,slaver1:9092,slaver2:9092

4.如果使用kafka自带的zookeeper（安装第三方zookeeper的请跳过这一步）

请修改配置文件下的zookeeper.properties文件，修改方法和上面第三方zookeeper配置相同（参看上述链接博客）

四、启动&停止集群命令

1.启动zookeeper

## 先启动好zookeeper
## 如果使用第三方的zookeeper使用下面这条命令
zkServer.sh start
## 如果使用kafka自带的zookeeper，进入kafka的bin目录里执行一下命令
./zookeeper-server-start.sh ../config/zookeeper.properties & 

2.启动kafka

## 启动kafka
cd /opt/apply/kafka_2.12-2.5.1/bin
## 前台运行
./kafka-server-start.sh ../config/server.properties
## 后台运行
./kafka-server-start.sh -daemon ../config/server.properties &

3.停止kafka

## 停止kafka
cd /opt/kafka/kafka_2.12-2.5.0/bin
./kafka-server-stop.sh