kafka叢集部署安裝

準備工作

安裝 JDK1.8

建立 zk使用者

全程切換到 zk使用者

需搭建好Zookeeper叢集，參見文章：https://blog.csdn.net/u011125375/article/details/103023393

kafka下載下傳連結：https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.2.0/kafka_2.11-2.2.0.tgz

1. 下載下傳後解壓, 全程在/home/zk/目錄下操作

tar -zxvf kafka_2.11-2.2.0.tgz
           

2. 在每台機器上/home/zk/目錄下建立

mkdir -p data/kafka
           

3. 分發kafka安裝包到其他機器

scp -r kafka_2.11-2.2.0 192.168.13.129:`pwd`
scp -r kafka_2.11-2.2.0 192.168.13.130:`pwd`
           

4. 修改每台機器/home/zk/kafka_2.11-2.2.0/config/server.properties 檔案

每台機器的log.dir值都為：

log.dir=/home/zk/data/kafka

修改每台機器broker.id屬性，值分别為：

broker.id=0、broker.id=1、broker.id=2

給每台機器添加listeners屬性，值分别為：

listeners=PLAINTEXT://192.168.13.128:9092

listeners=PLAINTEXT://192.168.13.129:9092

listeners=PLAINTEXT://192.168.13.130:9092

5. 啟動kafka

在每台機器執行

cd /home/zk/kafka_2.11-2.2.0
bin/kafka-server-start.sh config/server.properties &
           

6. 測試kafka

建立topic

bin/kafka-topics.sh --zookeeper 192.168.13.128:2181 --create --topic test --partitions 3 --replication-factor 2
           

消費topic

生産topic

向pruducer指令行輸入幾條消息， 若consumer可以成功接受，說明kafka叢集正常

Thanks !