前言

本節(jié)內(nèi)容主要介紹kafka3.0版本以后，一種新的kafka集群搭建模式看kraft，在該模式下，kafka高可用不在依賴于zookeeper，用 controller 節(jié)點代替 zookeeper，元數(shù)據(jù)保存在 controller 中，由 controller 直接進(jìn) 行 Kafka 集群管理。

正文

①解壓kafka安裝包到/opt/module/kafka-kraft目錄下

- 命令：

mkdir -p /opt/module/kafka-kraft
tar -zxvf kafka_2.12-3.0.0.tgz -C /opt/module/kafka-kraft

②修改kafka目錄下/opt/module/kafka-kraft/kafka_2.12-3.0.0/config/kraft的配置文件server.properties

?-?server.properties配置文件目錄

- 服務(wù)器基礎(chǔ)配置

############################# Server Basics #############################

# The role of this server. Setting this puts us in KRaft mode
process.roles=broker,controller

# The node id associated with this instance's roles
node.id=1

# The connect string for the controller quorum
controller.quorum.voters=1@hadoop101:9093,2@hadoop102:9093,3@hadoop103:9093

- 對外暴露地址的配置

advertised.listeners=PLAINTEXT://hadoop101:9092

- 配置數(shù)據(jù)存儲目錄

log.dirs=/opt/module/kafka-kraft/kafka_2.12-3.0.0/data

③同步kafka的kraft模式安裝包到hadoop102和hadoop103，并修改配置

?- 同步kafka安裝包

- 修改hadoop102的server.properties配置文件

- 修改hadoop103的server.properties配置文件

④初始化kafka-kraft集群數(shù)據(jù)目錄

-??生成存儲目錄唯一 ID

bin/kafka-storage.sh random-uuid

-?用該ID格式化kafka集群的存儲目錄

bin/kafka-storage.sh format -t 4l-ahopRSLSJlH-qxczhYg -c /opt/module/kafka-kraft/kafka_2.12-3.0.0/config/kraft/server.properties

⑤創(chuàng)建kafka集群啟停腳本

?- 在kafka的bin目錄創(chuàng)建集群啟停腳本my-kafka-kraft.sh

#! /bin/bash
case $1 in
"start"){
 for i in hadoop101 hadoop102 hadoop103
 do
 echo " --------啟動 $i Kafka2-------"
 ssh $i "/opt/module/kafka-kraft/kafka_2.12-3.0.0/bin/kafka-server-start.sh -daemon /opt/module/kafka-kraft/kafka_2.12-3.0.0/config/kraft/server.properties"
 done
};;
"status"){
 for i in hadoop101 hadoop102 hadoop103
 do
 echo =============== $i ===============
 ssh $i jps
 done
};;
"stop"){
 for i in hadoop101 hadoop102 hadoop103
 do
 echo " --------停止 $i Kafka2-------"
 ssh $i "/opt/module/kafka-kraft/kafka_2.12-3.0.0/bin/kafka-server-stop.sh "
 done
};;
esac

- 在hadoop101服務(wù)器創(chuàng)建my-kafka-kraft.sh腳本

?⑥配置kafka-kraft環(huán)境變量

- 修改環(huán)境變量配置

- 同步環(huán)境變量配置

⑦啟動集群、停止集群、查看集群狀態(tài)

?

結(jié)語

至此，關(guān)于kafka集群之Kraft模式安裝與部署到這里就結(jié)束了，我們下期見。。。。。。文章來源地址http://www.zghlxwxcb.cn/news/detail-712599.html

到了這里，關(guān)于（二十六）大數(shù)據(jù)實戰(zhàn)——kafka集群之Kraft模式安裝與部署的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！