安裝JDK
https://www.cnblogs.com/fengyumeng/p/13875508.html
安裝zookeeper
https://zookeeper.apache.org/releases.html
本文用的版本是3.7.0
解壓：tar -zxvf apache-zookeeper-3.7.0-bin.tar.gz
移走：mv apache-zookeeper-3.7.0-bin /usr/local/zookeeper
生成配置文件
cp /usr/local/zookeeper/conf/zoo_sample.cfg /usr/local/zookeeper/conf/zoo.cfg
編輯配置文件
vim /usr/local/zookeeper/conf/zoo.cfg
修改數據目錄：dataDir=/usr/local/zookeeper/data
這里不配集群版，我在雲服務器上搭的，配不起。
創建數據目錄
mkdir /usr/local/zookeeper/data
添加環境變量
vim /etc/profile
在最下面增加一行：PATH=$PATH:/usr/local/zookeeper/bin
使配置生效：source /etc/profile
啟動
zkServer.sh start
停止
zkServer.sh stop
重啟
zkServer.sh restart
狀態
zkServer.sh status
安裝kafka
下載頁面：http://kafka.apache.org/downloads
本文使用的版本是kafka_2.13-2.8.0
解壓
tar -zxvf kafka_2.13-2.8.0.tgz
移走
mv kafka_2.13-2.8.0 /usr/local/kafka
修改配置文件
vim /usr/local/kafka/config/server.properties
修改
log.dirs=/usr/local/kafka/logs
advertised.listeners=PLAINTEXT://127.0.0.1:9092
創建日志目錄
mkdir /usr/local/kafka/logs
啟動
/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties
停止
/usr/local/kafka/bin/kafka-server-stop.sh /usr/local/kafka/config/server.properties
測試通信
cd /usr/local/kafka/bin/
使用生產者生產消息
./kafka-console-producer.sh --broker-list localhost:9092 --topic a
使用消費者消費消息
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic a --from-beginning
查看topic
./kafka-topics.sh --list --zookeeper localhost:2181