說明：教程使用4台服務器，1台用作zookeeper，3台用kafka
必備條件:jdk
kafka自帶zookeeper 也可以使用kafka內置的zookeeper
一、zookeeper下載安裝
1、首先去官網下載zookeeper：https://downloads.apache.org/zookeeper/
進入目錄下載
2、下載好放到一台zookeeper服務器上面解壓
tar zxvf apache-zookeeper-3.5.7-bin.tar.gz -C ./
3、進入conf目錄下，復制zoo_sample.cfg文件，名字為zoo.cfg (不然啟動找不到該文件)
cd ./apache-zookeeper-3.5.7-bin/conf cp zoo_sample.cfg ./zoo.cfg
4、啟動服務
#啟動
sh zkServer.sh start
#查看啟動狀態
sh ./zkServer.sh status
啟動成功
二、kafka下載安裝
1、首先去官網下載zookeeper：http://kafka.apache.org/downloads
2、下載好放到kafka服務器上面解壓
tar zxvf kafka_2.12-2.3.0.tgz -C ./
3、在config目錄下配置集群
vi server.properties
1、把broker.id改0，1，2 三台機器不一樣
broker.id=0
2、把listeners生效，並加上本機ip
listeners=PLAINTEXT://本機ip:9092
3、指定zookeeper連接地址，改為zookeeper服務器地址
zookeeper.connect=192.168.88.137:2181
4、啟動kafka，三台機器啟動
sh kafka-server-start.sh -daemon ../config/server.properties
#查看zookeeper
ps -ef|grep zookeeper
可以看kafka日志文件是否有報錯
啟動完成后，查看zookeeper集群連接情況
1.進入zookeeper的bin目錄下執行
sh zkCil.sh
#查看 執行
ls /
#查看連接情況
ls /brokers/ids
5、任意一台機器 新建topic
sh kafka-topics.sh --create --zookeeper 192.168.88.137:2181 --replication-factor 1 --partitions 1 --topic test
#說明
#192.168.88.137:2181 ###這是zookeeper服務ip+端口號
#test ###這是topic
6、使用任意一台kafka服務器做生產者
sh kafka-console-producer.sh --broker-list 192.168.88.132:9092 --topic test
7、使用三台kafka消費
./kafka-console-consumer.sh --bootstrap-server 192.168.88.132:9092 --topic test --from-beginning
動態圖如下：
