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