注意：低版本需要安裝zookeeper，在2.8及以上可移除zookeeper
前往官網(wǎng)下載
?。?！不要下載src文件
1.解壓文件
tar xzf kafka_2.13-3.4.0.tgz
進入文件
cd kafka_2.13-3.4.0
進入
cd config/kraft
2.修改server.properties以下屬性
vim server.properties
3.我們需要在啟動服務器之前創(chuàng)建kafka集群id。執(zhí)行下列命令，并記下運行生成的uuid：
./bin/kafka-storage.sh random-uuid
Z_aPqvh6SPyxIIHEo9Os8A
?。?！只需要一個集群ID
4.接下來我們格式化所有存儲目錄：
#server1
./bin/kafka-storage.sh format -t Z_aPqvh6SPyxIIHEo9Os8A -c ./config/kraft/server.properties
#server2
./bin/kafka-storage.sh format -t Z_aPqvh6SPyxIIHEo9Os8A -c ./config/kraft/server.properties
#server3
./bin/kafka-storage.sh format -t Z_aPqvh6SPyxIIHEo9Os8A -c ./config/kraft/server.properties
5.可以使用以下命令在守護程序模式下啟動kafka服務器
#server1
./bin/kafka-server-start.sh -daemon ./config/kraft/server.properties
#server2
./bin/kafka-server-start.sh -daemon ./config/kraft/server.properties
#server3
./bin/kafka-server-start.sh -daemon ./config/kraft/server.properties
jps查看是否啟動
6.使用以下命令創(chuàng)建hello-kraft topic：
./bin/kafka-topics.sh --create --topic hello-kraft --partitions 3 --replication-factor 3 --bootstrap-server 10.136.3.201:9091
7.生產(chǎn)和消費kafka數(shù)據(jù)
使用以下命令開啟一個生產(chǎn)者
bin/kafka-console-producer.sh --broker-list 10.136.3.201:9091 --topic hello-kraft
在另一個終端中，使用以下命令啟動消費者，注意，監(jiān)聽的集群另一個節(jié)點
bin/kafka-console-consumer.sh --bootstrap-server 10.136.3.202:9092 --topic hello-kraft
測試：生產(chǎn)者輸入 成功
消費者消費
列出所有topic查看文章來源：http://www.zghlxwxcb.cn/news/detail-436576.html
bin/kafka-topics.sh --list --bootstrap-server 10.136.3.201:9091文章來源地址http://www.zghlxwxcb.cn/news/detail-436576.html
到了這里，關于kafka3.4.0集群搭建（無zookeeper）的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章，希望大家以后多多支持TOY模板網(wǎng)！
