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-logs
zookeeper.connect=spark1:2181,spark2:2181,spark3:2181
broker.id=0
host.name=spark1
port=9092
message.max
.byte=5242880
default.replication
.factor=2
replica.fetch
.max
.bytes=5242880
只有對其他的機器進行相同的操作
注意 這個兩個引數
broker.id=0
host.name=spark1
進入到bin 目錄下
執行 ./kafka-server-start.sh -daemon ../config/server.properties
三颱都要執行
可以通過jps 檢視啟動狀態
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....
kafka集群安裝
kafka 是乙個分布式 的基於發布 訂閱模式的訊息佇列 messagequeue 主要應用於大資料實時處理領域。2 解壓安裝包,解壓到 usr local下面 tar zxvf kafka 2.11 0.11.0.0.tgz c usr local 解壓之後修改名稱 mv kafka 2.11 0...
kafka集群安裝
kafka是分布式的,需要多台機器,並且保證機器之間是免密登入,同時需要用zookeeper集群負責管理 2 brokers節點分配,注意一定是奇數臺節點 3 解壓並軟鏈 tar zxvf software kafka 2.11 0.11.0.3.tgz ln sf kafka 2.11 0.11....