只講操作，不講原理，不帶說明。

PS：如果下面例子中給出的鏡像地址不能用的話，就去官網(wǎng)找最新版

機(jī)器&java環(huán)境

• 準(zhǔn)備1臺(tái)centos機(jī)器
• 配置java環(huán)境

zookeeper 配置

• 創(chuàng)建一個(gè)你想要安裝 zookeeper 的工作目錄。
• 創(chuàng)建一個(gè)你想要保存 zookeeper 數(shù)據(jù)的工作目錄。
• zookeeper 下載：wget https://dlcdn.apache.org/zookeeper/zookeeper-3.7.0/apache-zookeeper-3.7.0-bin.tar.gz
• zookeeper 解壓：tar -zxvf zookeeper......tar.gz
• 配置環(huán)境變量
  • export ZOOKEEPER_INSTALL=/home/你的zk安裝路徑
  • export PATH=$PATH:$ZOOKEEPER_INSTALL/bin
• 修改配置文件（conf目錄）
  • 進(jìn)入conf目錄：cd zookeeper-3.3.6/conf
  • 創(chuàng)建配置文件：cp zoo_sample.cfg zoo.cfg
  • 配置 zoo.cfg
    • dataDir 改到一個(gè)單獨(dú)的目錄下，自己定義就好。
    • 加一行配置：server.1=本機(jī)ip地址:2888:3888
• 服務(wù)管理（bin目錄）
  • 進(jìn)入bin目錄：./zkServer.sh start 啟動(dòng)zk。
  • 查看zk服務(wù)狀態(tài)：sh zkServer.sh status
  • 連接zk
    • 本地：./zkCli.sh
    • 遠(yuǎn)程：./zkCli.sh -server 你要連接的遠(yuǎn)程ip地址:端口
  • 關(guān)閉zk：sh bin/zkServer.sh stop
  • 重啟zk：sh bin/zkServer.sh restart

ps：zookeeper 下載地址可以直接去官網(wǎng)找，記得找?guī)?-bin 后綴的，不然會(huì)報(bào)錯(cuò)”找不到或無法加載主類 org.apache.zookeeper.server.quorum.QuorumPeerMain“。

kafka

• 創(chuàng)建一個(gè)你想要安裝 kafka 的工作目錄。
• 創(chuàng)建一個(gè)你想要保存 kafka 數(shù)據(jù)的目錄和日志目錄。
• kafka下載：wget https://archive.apache.org/dist/kafka/2.8.1/kafka_2.12-2.8.1.tgz
• kafka解壓：tar -zxvf kafka......tgz
• 配置環(huán)境變量：
  • export KAFKA_INSTALL=/home/你的kafka安裝路徑
  • export PATH=$PATH:$KAFKA_INSTALL/bin
• 修改配置文件（config目錄）
  • 進(jìn)入config目錄：cd config
  • 修改 server.properties 文件：vim server.properties
    • 把 log.dirs 改成你自己創(chuàng)建的日志存儲(chǔ)目錄。
    • 加一行端口配置：port=9092
• 服務(wù)管理（bin目錄）
  • 前臺(tái)啟動(dòng)kafka：sh kafka-server-start.sh ../config/server.properties
  • 后臺(tái)啟動(dòng)kafka：sh kafka-server-start.sh ../config/server.properties & 或 ./kafka-server-start.sh ../config/server.properties 1>/dev/null 2>&1 &
  • 查看kafka運(yùn)行狀態(tài)：jps
  • 關(guān)閉kafka：kafka-server-stop.sh
• 來跑個(gè)demo（bin目錄）
  • 創(chuàng)建一個(gè)topic（名為test）：sh kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
  • 查看 topic 列表：sh kafka-topics.sh --list --zookeeper localhost:2181
  • 創(chuàng)建 producer：sh kafka-console-producer.sh --broker-list localhost:9092 --topic test
  • 創(chuàng)建 consumer：sh kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
  • 在 producer 控制臺(tái)輸入消息回車發(fā)送，consumer 控制臺(tái)可以查看到。

ps：kafka 下載地址可以去官網(wǎng)找，帶 src 后綴的需要編譯、不帶 src 的不需要編譯。