一、Kafka环境搭建

点击下载kafka_2.11-2.3.1.tgz文件链接

1、上传kafka_2.11-2.3.1.tgz，解压kafka_2.11-2.3.1.tgz，得到kafka_2.11-2.3.1文件夹

1）上传

#使用mobaxterm将 kafka_2.11-2.3.1.tgz 传入tools文件夹
#用下面代码进入tools文件夹

cd /tools

#查看传入成功没

ll

2）解压到training文件夹

tar -zxvf kafka_2.11-2.3.1.tgz -C /training

cd /training

2、 kafka需要安装zookeeper使用，但kafka集成zookeeper,在单机搭建时可直接使用。使用需配置kafka_2.11-2.3.1/config 下的“zookeeper.properties”

cd kafka_2.11-2.3.1/config

3、配置"zookeeper.properties"。修改dataDir和clientPort。前者是快照存放地址(自己随意配置)，后者是客户端连接zookeeper服务的端口。默认端口2181 最好默认不修改

1）进入zookeeper.properties配置

vi zookeeper.properties

2）配置内容，修改dataDir和clientPort。前者是快照存放地址(自己随意配置可以和我一样)，后者是客户端连接zookeeper服务的端口。默认端口2181 最好默认不修改

4、配置kafka_2.11-2.3.1/config下的“server.properties”，修改log.dirs和zookeeper.connect。前者是日志存放文件夹，后者是zookeeper连接地址（端口和clientPort保持一致）

vi server.properties

1）找 ### Log Basics ### 添加如图所示

log.dirs=/training/kafka_2.11-2.3.1/logs

2）找 ### Zookeeper ### 添加如图所示，注意修改主机名

#查询主机名我的主机名字是niit：

hostname

#配置截图

zookeeper.connect=niit:2181
listeners=PLAINTEXT://niit:9092
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=102400
socket.receive.buffer.bytes=102400
socket.request.max.bytes=104857600
num.partitions=3
num.recovery.threads.per.data.dir=1
offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=1
log.retention.hours=168
log.segment.bytes=1073741824
log.retention.check.interval.ms=300000
zookeeper.connection.timeout.ms=6000
group.initial.rebalance.delay.ms=0
auto.create.topics.enable=true
delete.topics.enable=true

到此，kafka的单机环境就搭建成功了。

二、kafka的相关命令

1、开启kafka自带zookeeper

1）窗口1

cd /training/kafka_2.11-2.3.1/

./bin/zookeeper-server-start.sh ./config/zookeeper.properties

2）窗口2

cd /training/kafka_2.11-2.3.1/

./bin/zookeeper-server-start.sh -daemon ./config/zookeeper.properties

2、开启kafka

1）窗口2

cd /training/kafka_2.11-2.3.1/

./bin/kafka-server-start.sh ./config/server.properties

2）窗口3

cd /training/kafka_2.11-2.3.1/

./bin/kafka-server-start.sh -daemon ./config/server.properties

使用jps命令查看进程。安装配置完毕。