Kafka-Kraft 模式
左圖為kafka現(xiàn)有架構(gòu)，元數(shù)據(jù)在zookeeper中，運行時動態(tài)選舉controller,由controller進行kafka集群管理，右圖為kraft模式架構(gòu)（實驗性），不再依賴zookeeper集群，而是用三臺controller節(jié)點代替zookeeper，元數(shù)據(jù)保存在controller中，由controller直接2進行kafka集群管理
好處：
1、kafka不再依賴外部框架，二十能夠獨立運行
2、controller管理集群時，不再需要從zookeeper中先讀取數(shù)據(jù)，集群性能上升
3、由于不依賴zookeeper，集群拓展不再收到zookeeper讀寫能力限制
4、controller不再東藥選舉，而是由配置文件規(guī)定，這樣我們可以針對性的加強controller節(jié)點的配置，而不是像以前一樣對隨機controller節(jié)點的高負債束手無策
部署
修改配置
解壓
修改config/kraft/server.properties下的注意路徑
vim config/kraft/server.properties
修改這4個地方分發(fā) 修改其他節(jié)點的node.id=2和advertised.Listeners
初始化集群
bin/kafka-storage.sh random-uuid
用該 ID （id要相同）格式化 kafka 存儲目錄，三臺機器都要執(zhí)行
bin/kafka-storage.sh format -t qtUYZ6KhQ5mlAxIg-T0M5w -c /usr/local/src/kafka/kraft/kafka_2.12-3.0.0/config/kraft/server.propertie
啟動命令
bin/kafka-server-start.sh -daemon config/kraft/server.properties
停止命令
bin/kafka-server-stop.sh文章來源：http://www.zghlxwxcb.cn/news/detail-548238.html
腳本
#! /bin/bash
case $1 in
"start"){
for i in hadoop100 hadoop101 hadoop102
do
echo " --------啟動 $i Kafka2-------"
ssh $i "/usr/local/src/kafka/kraft/kafka_2.12-3.0.0/bin/kafka-server-start.sh -daemon /usr/local/src/kafka/kraft/kafka_2.12-3.0.0/config/kraft/server.properties"
done
};;
"stop"){
for i in hadoop102 hadoop103 hadoop104
do
echo " --------停止 $i Kafka2-------"
ssh $i "/usr/local/src/kafka/kraft/kafka_2.12-3.0.0/bin/kafka-server-stop.sh "
done
};;
esac
文章來源地址http://www.zghlxwxcb.cn/news/detail-548238.html
到了這里，關(guān)于Kafka入門， Kafka-Kraft 模式 部署（二十六）的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
