建站
咨詢
售后
建站咨詢
新聞中心
本篇內(nèi)容介紹了“Kafka安裝部署方法及簡(jiǎn)單命令”的有關(guān)知識(shí)，在實(shí)際案例的操作過程中，不少人都會(huì)遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！
創(chuàng)新互聯(lián)公司長(zhǎng)期為上1000+客戶提供的網(wǎng)站建設(shè)服務(wù)，團(tuán)隊(duì)從業(yè)經(jīng)驗(yàn)10年，關(guān)注不同地域、不同群體，并針對(duì)不同對(duì)象提供差異化的產(chǎn)品和服務(wù)；打造開放共贏平臺(tái)，與合作伙伴共同營(yíng)造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為社旗企業(yè)提供專業(yè)的網(wǎng)站建設(shè)、成都網(wǎng)站建設(shè)，社旗網(wǎng)站改版等技術(shù)服務(wù)。擁有10多年豐富建站經(jīng)驗(yàn)和眾多成功案例,為您定制開發(fā)。
2.1安裝部署
2.1.1 集群規(guī)劃
本例使用單機(jī)集群方式，在本地啟用三份程序組成集群， 使用一個(gè)Zookeeper集群。
需要
1.安裝JDK8 Deepin 安裝jdk1.8
2.配置Zookeeper集群，參見 Zookeeper單機(jī)為偽集群
2.1.2 jar包下載
地址： http://kafka.apache.org/downloads.html
2.1.3 集群部署
解壓安裝包
tar -zxvf kafka_2.12-2.7.0.tgz -C /usr/local/kafka/
2. 修改解壓后的文件名稱
/usr/local/kafka/kafka01
3. 創(chuàng)建logs文件夾
4. 需要修改的配置文件內(nèi)容：
broker.id=0 #broker的id 每個(gè)節(jié)點(diǎn)一個(gè)不能重復(fù)，本例中三個(gè)節(jié)點(diǎn)分別為0,1,2 delete.topic.enable=true #開啟刪除topic功能## host.name=127.0.0.1 #本機(jī)名或者ip port=9091 #默認(rèn)為9092 每個(gè)id內(nèi)Kakfa服務(wù)器監(jiān)聽的端口 log.dirs=/usr/local/kafka/kafka01/logs #日志存放路徑 zookeeper.connect=127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183 #zookeeper連接端口
5. 復(fù)制 /kafka01 到 kafka02,kafka03
6.修改kafka02,kafka03對(duì)應(yīng)的配置
kafka02/config/server.properties
broker.id=1 #broker的id 每個(gè)節(jié)點(diǎn)一個(gè)不能重復(fù)，本例中三個(gè)節(jié)點(diǎn)分別為0,1,2 delete.topic.enable=true #開啟刪除topic功能## host.name=127.0.0.1 #本機(jī)名或者ip port=9092 #默認(rèn)為9092 每個(gè)id內(nèi)Kakfa服務(wù)器監(jiān)聽的端口 log.dirs=/usr/local/kafka/kafka02/logs #日志存放路徑 zookeeper.connect=127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183 #zookeeper連接端口
kafka03/config/server.properties
broker.id=2 #broker的id 每個(gè)節(jié)點(diǎn)一個(gè)不能重復(fù)，本例中三個(gè)節(jié)點(diǎn)分別為0,1,2 delete.topic.enable=true #開啟刪除topic功能## host.name=127.0.0.1 #本機(jī)名或者ip port=9093 #默認(rèn)為9092 每個(gè)id內(nèi)Kakfa服務(wù)器監(jiān)聽的端口 log.dirs=/usr/local/kafka/kafka03/logs #日志存放路徑 zookeeper.connect=127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183 #zookeeper連接端口
7.啟動(dòng)集群
先啟動(dòng)zookeeper集群
/usr/local/zookeeper/zookeeper01/bin/zkServer.sh start /usr/local/zookeeper/zookeeper02/bin/zkServer.sh start /usr/local/zookeeper/zookeeper03/bin/zkServer.sh start
再啟動(dòng)kafka集群
root@bluejay-PC:/# /usr/local/kafka/kafka01/bin/kafka-server-start.sh -daemon /usr/local/kafka/kafka01/config/server.properties root@bluejay-PC:/# /usr/local/kafka/kafka02/bin/kafka-server-start.sh -daemon /usr/local/kafka/kafka02/config/server.properties root@bluejay-PC:/# /usr/local/kafka/kafka03/bin/kafka-server-start.sh -daemon /usr/local/kafka/kafka03/config/server.properties
8. 關(guān)閉集群
root@bluejay-PC:/# /usr/local/kafka/kafka01/bin/kafka-server-stop.sh root@bluejay-PC:/# /usr/local/kafka/kafka02/bin/kafka-server-stop.sh root@bluejay-PC:/# /usr/local/kafka/kafka03/bin/kafka-server-stop.sh
9.kafka群起腳本
2.2 Kafka命令行操作
1. 創(chuàng)建topic
root@bluejay-PC:/# /usr/local/kafka/kafka03/bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183 --replication-factor 1 --partitions 1 --topic first Created topic first.
2. 查看當(dāng)前服務(wù)器中的所有 topic
root@bluejay-PC:/# /usr/local/kafka/kafka03/bin/kafka-topics.sh --list --zookeeper 127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183 first
3. 消費(fèi)消息-開啟監(jiān)聽
root@bluejay-PC:/# /usr/local/kafka/kafka01/bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9091 --topic first
4. 發(fā)送消息
root@bluejay-PC:/# /usr/local/kafka/kafka03/bin/kafka-console-producer.sh --broker-list 127.0.0.1:9091 --topic first >hello world >atguigu atguigu >zhanghl^H^H^H >end > >^C
5. 查看某個(gè)Topic的詳情
root@bluejay-PC:/# /usr/local/kafka/kafka01/bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --describe --topic first Topic: first PartitionCount: 1 ReplicationFactor: 1 Configs: Topic: first Partition: 0 Leader: 2 Replicas: 2 Isr: 2
6. 修改分區(qū)數(shù)
root@bluejay-PC:/# /usr/local/kafka/kafka01/bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic first --partitions 6 WARNING: If partitions are increased for a topic that has a key, the partition logic or ordering of the messages will be affected Adding partitions succeeded!
7. 刪除topic
root@bluejay-PC:/# /usr/local/kafka/kafka01/bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --delete --topic first
“Kafka安裝部署方法及簡(jiǎn)單命令”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實(shí)用文章！
文章題目：Kafka安裝部署方法及簡(jiǎn)單命令
網(wǎng)站網(wǎng)址：http://ef60e0e.cn/article/jsgihd.html
