如下有3臺(tái)虛擬機(jī)，對(duì)應(yīng)的IP如下：

下一臺(tái)

下一臺(tái)

對(duì)應(yīng)的3給IP地址如下：

192.168.94.129

192.168.94.131

192.168.94.132

?

?

這里默認(rèn)jdk?1.8是安裝好了的。

?

?

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

解壓后進(jìn)入zookeeper，的conf。拷貝一份zoo_sample.cfg為zoo.cfg

修改zoo.cfg

上面3臺(tái)服務(wù)器都是需要這樣配置。并且再/tmp/zookeeper創(chuàng)建一個(gè)myid文件，寫(xiě)入server.x中的x，這個(gè)x。如192.168.94.129中myid為0，192.168.94.131中myid為1

在bin目錄里面啟動(dòng)

./zkServer.sh start

這里會(huì)在conf下自動(dòng)去找zoo.cfg文件

如果有問(wèn)題會(huì)出現(xiàn)到

zookeep.out文件夾中記錄出現(xiàn)的錯(cuò)誤，有問(wèn)題就查看這個(gè)文件。啟動(dòng)成功后。

?

上面每一臺(tái)都要這么做。

?

輸入./zkServer.sh?status查看狀態(tài)：

下面是搭建集群kafka

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

添加如下數(shù)據(jù)：

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

這個(gè)broker.id=0為/tmp/zookeeper/myid的id。

?

再修改

meta.properties文件如下

把broker.id添加當(dāng)前myid的值。

?

隨后就可以啟動(dòng)kafka了。集群就搭建好了

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

這里報(bào)錯(cuò)信息會(huì)打印到前端，有問(wèn)題要即使處理。

?

添加一個(gè)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

就可以發(fā)送消息了：

隨便找某一臺(tái)進(jìn)行消費(fèi)

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

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來(lái)咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的Kafka笔记-Kafka集群搭建的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。