首先確認安裝jdk8及以上版本,
確認已安裝zookeeper,zookeeper-3.4.12安裝步驟
選擇 kafka_2.11-2.0.0.tgz版本,複製到安裝目錄,解壓縮
第二步:修改配置檔案
# borker的編號,如果集群中有多個,則每個borker需設定不同的編號
broker.id=0
#broker對外提供服務入口的埠(預設9092)
listeners=plaintext:/
/:9092
#存放訊息日誌檔案位址
log.dirs=/
data
/home/quyanhang/study/kafka/kafkadata/kafka-logs
# kafka所需zookeeper集群位址
zookeeper.connect=localhost:2181
第三步:啟動
在kafka安裝目錄下執行啟動命令
bin/kafka-server-
start
.sh config/server.properties
啟動成功:
如果後台啟動,則在啟動命令加 -daemon或者&
.
/bin/kafka-server-
start
.sh config/server.properties &或者.
/bin/kafka-server-
start
.sh -daemon config/server.properties
通過jps檢視kafka是否啟動
將解壓後的安裝包複製到不同哦個目錄,修改配置檔案
kafka-1節點配置檔案
# borker的編號,如果集群中有多個,則每個borker需設定不同的編號
broker.id=1
#broker對外提供服務入口的埠(預設9092)
listeners=plaintext:/
/:19092
#存放訊息日誌檔案位址
log.dirs=/
data
/home/quyanhang/study/kafka/kafkadata-1/kafka-logs
# kafka所需zookeeper集群位址
zookeeper.connect=localhost:21810,localhost:21811,localhost:21812
kafka-2節點配置檔案
# borker的編號,如果集群中有多個,則每個borker需設定不同的編號
broker.id=2
#broker對外提供服務入口的埠(預設9092)
listeners=plaintext:/
/:29092
#存放訊息日誌檔案位址
log.dirs=/
data
/home/quyanhang/study/kafka/kafkadata-2/kafka-logs
# kafka所需zookeeper集群位址
zookeeper.connect=localhost:21810,localhost:21811,localhost:21812
kafka-3節點配置檔案
# borker的編號,如果集群中有多個,則每個borker需設定不同的編號
broker.id=3
#broker對外提供服務入口的埠(預設9092)
listeners=plaintext:/
/:39092
#存放訊息日誌檔案位址
log.dirs=/
data
/home/quyanhang/study/kafka/kafkadata-3/kafka-logs
# kafka所需zookeeper集群位址
zookeeper.connect=localhost:21810,localhost:21811,localhost:21812
分別啟動三個節點,啟動成功後可用指令碼進行驗證
kafka指令碼收發訊息
kafka集群搭建步驟
1 搭建軟體環境 1 linux一台或多台,大於等於2 2 已經搭建好的zookeeper集群 2 解壓tar zxvf kafka 2.10 0.10.1.1.tgz 3 在kafka安裝目錄下,新建目錄kafkalogs 4 在config目錄下修改配置檔案server.properties,b...
安裝kafka 集群
wget org kafka 1.0 0 kafka 2.11 1.0 0.tgz tar zxvf kafka 2.11 1.0 0.tgz vi kafka 2.11 1.0 0 config server.properties主要修改的有如下 log.dirs home data kafka ...
kafka集群安裝
請參考上一章zookeepe集群安裝 wget org kafka 0.9 0.1 kafka 2.11 0.9 0.1 tgz tar xzf kafka 2.11 0.9 0.0 tgzbroker.id 0 整個集群內唯一id號,整數,一般從0開始 listeners plaintext 1....