請參考上一章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
.tgz
broker.id=0
#整個集群內唯一id號，整數，一般從0開始
listeners=plaintext:
.1.201:9092
#協議、當前broker機器ip、埠，此值可以配置多個，應該跟ssl等有關係，更多用法尚未弄懂，這裡修改為ip和埠。
port=9092
#broker埠
host.name=192.168
.1.201
#broker 機器ip
log.dirs=/data/kafka-logs/kafka00 #kafka儲存資料的目錄
zookeeper.connect=192.168
.1.201:2181,192.168
.1.201:2182,192.168
.1.201:2183
#zookeeper 集群列表
broker.id=1
listeners=plaintext:
.1.201:9093
port=9093
host.name=192.168
.1.201
log.dirs=/data/kafka-logs/kafka01
zookeeper.connect=192.168
.1.201:2181,192.168
.1.201:2182,192.168
.1.201:2183
broker.id=2
listeners=plaintext:
.1.201:9094
port=9094
host.name=192.168
.1.201
log.dirs=/zyxx_data/kafka-logs/kafka02
zookeeper.connect=192.168
.1.201:2181,192.168
.1.201:2182,192.168
.1.201:2183
bin/kafka-server
-start
.sh -daemon config/server.properties
bin/kafka-server
-start
.sh -daemon config/server-
1.properties
bin/kafka-server
-start
.sh -daemon config/server-
2.properties
官網及網上大多給的啟動命令是沒有」-daemon」引數，如：「bin/kafka-server-start.sh config/server.properties &」，但是這種方式啟動後，如果使用者退出的ssh連線，程序就有可能結束，具體不清楚為什麼。
我們可以通過以下命令檢視kafka server是否已啟動
ps -ef | grep config/server
安裝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集群安裝
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....