如下有3臺虛擬機，對應的IP如下：

下一臺

下一臺

對應的3給IP地址如下：

192.168.94.129

192.168.94.131

192.168.94.132

?

?

這里默認jdk?1.8是安裝好了的。

?

?

首先是安裝zookeeper，分布式部署，隨后再部署kafka

解壓后進入zookeeper，的conf?？截愐环輟oo_sample.cfg為zoo.cfg

修改zoo.cfg

上面3臺服務器都是需要這樣配置。并且再/tmp/zookeeper創建一個myid文件，寫入server.x中的x，這個x。如192.168.94.129中myid為0，192.168.94.131中myid為1

在bin目錄里面啟動

./zkServer.sh start

這里會在conf下自動去找zoo.cfg文件

如果有問題會出現到

zookeep.out文件夾中記錄出現的錯誤，有問題就查看這個文件。啟動成功后。

?

上面每一臺都要這么做。

?

輸入./zkServer.sh?status查看狀態：

下面是搭建集群kafka

解壓kafka后修改config下面的server.properties

添加如下數據：

broker.id=0 listeners=PLAINTEXT://192.168.94.129:9092 zookeeper.connect=192.168.94.129:2181,192.168.94.131:2181,192.168.94.132:2181

這個broker.id=0為/tmp/zookeeper/myid的id。

?

再修改

meta.properties文件如下

把broker.id添加當前myid的值。

?

隨后就可以啟動kafka了。集群就搭建好了

在bin目錄下./kafka-server-start.sh?../config/server.properties

這里報錯信息會打印到前端，有問題要即使處理。

?

添加一個topic

./kafka-topics.sh --create --zookeeper 192.168.94.129:2181,192.168.94.131:2181,192.168.94.132:2181 --partitions 3 --replication-factor 3 --topic HelloWorld

往topic里面添加消息

./kafka-console-producer.sh --broker-list 192.168.94.129:9092,192.168.94.131:9092,192.168.94.132:9092 --topic HelloWorld

就可以發送消息了：

隨便找某一臺進行消費

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic HelloWorld --from-beginning

創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎

總結

以上是生活随笔為你收集整理的Kafka笔记-Kafka集群搭建的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。