IT培訓(xùn)網(wǎng)
IT培訓(xùn)
Java培訓(xùn)
軟件測試培訓(xùn)
Web培訓(xùn)
Linux培訓(xùn)
Python培訓(xùn)
互聯(lián)網(wǎng)營銷培訓(xùn)
UI培訓(xùn)
大數(shù)據(jù)培訓(xùn)關(guān)注我們
官方公眾號 回復(fù)"大禮包"享福利 
領(lǐng)學(xué)習(xí)資料 分享IT知識 IT在線學(xué)習(xí)
熱門課程 更多 >
關(guān)注我們
掃碼領(lǐng)資料 零基礎(chǔ)學(xué)IT 微信掃碼關(guān)注 回復(fù)“大禮包”享福利 IT培訓(xùn)網(wǎng)
官方公眾號 回復(fù)"大禮包"享福利 領(lǐng)學(xué)習(xí)資料 分享IT知識 IT在線學(xué)習(xí)
掃碼領(lǐng)資料 零基礎(chǔ)學(xué)IT 微信掃碼關(guān)注 回復(fù)“大禮包”享福利 
閱讀()
分享
手機(jī)端入口
一、 安裝JDK &配置JAVA_HOME
JDK安裝和JAVA_HOME配置，大家都應(yīng)該很熟悉了，我們在此不再贅述。
二、 安裝Zookeeper
參照Zookeeper官網(wǎng)搭建一個ZK集群， 并啟動ZK集群。
三、 解壓Kafka安裝包
1. 修改配置文件config/server.properties
vi server.properties
broker.id=0 //集群中唯一id,依次增長：0、1、2、3、4
log.dirs=/root/kafkaData/ // 設(shè)置Kafka的消息數(shù)據(jù)存儲路徑
zookeeper.connect=node1:2181,node2:2181,node3:2181 //zookeeperServers列表，節(jié)點(diǎn)間以逗號分開
delete.topic.enable=true
listeners=PLAINTEXT:/node1:9092
log.dirs=/root/kafkaData/
num.partitions=3
# 往其他節(jié)點(diǎn)分發(fā)安裝包
for i in 2 3 ; do scp -r kafka_2.11-0.10.2.1/node$i:$PWD ;done
在其它幾臺節(jié)點(diǎn)上，分別修改此配置文件：broker.id依次增長。
2. 啟動Kafka
啟動kafka之前，必須要保證在每個節(jié)點(diǎn)上zookeeper都是啟動的。
在每個節(jié)點(diǎn)上啟動Kafka：
bin/kafka-server-start.sh [-daemon] config/server.properties
3. 集群測試
(1)進(jìn)入kafka根目錄，創(chuàng)建test主題(topic)
bin/kafka-topics.sh --create --zookeeper node1:2181,node2:2181,node3:2181 --replication-factor 3 --partitions 1 --topic test
(2)顯示已創(chuàng)建的topic列表
bin/kafka-topics.sh --list --zookeeper node1:2181
>>本文地址：http://www.028benet.com/zhuanye/2020/48582.html
聲明:本站稿件版權(quán)均屬中公教育優(yōu)就業(yè)所有，未經(jīng)許可不得擅自轉(zhuǎn)載。
1 您的年齡
2 您的學(xué)歷
3 您更想做哪個方向的工作？
大前端
大數(shù)據(jù)
互聯(lián)網(wǎng)營銷
Java
Linux
Python
嵌入式
全域電商運(yùn)營
軟件測試
室內(nèi)設(shè)計
平面設(shè)計
電商設(shè)計
網(wǎng)頁設(shè)計
UI設(shè)計
VR/AR
網(wǎng)絡(luò)安全
新媒體
直播帶貨
智能機(jī)器人
中公教育IT培訓(xùn)品牌
400-650-7353
Copyright©1999-
北京中公教育科技有限公司 .All Rights Reserved
京ICP備10218183號-88
京ICP證161188號
京公網(wǎng)安備11010802020723號
投訴建議：400-650-7353
