前言:
linux系統版本:CentOS6.7
JDK版本:1.8(JDK安裝過程參考:點選打開連結)
ZooKeeper版本:3.4.6(ZooKeeper安裝過程參考:點選打開連結)
Kafka版本:1.1.0
安裝
step1 下載下傳并解壓
wget http://mirrors.shu.edu.cn/apache/kafka/1.1.0/kafka_2.11-1.1.0.tgz
tar –zxvf kafka_2.11-1.1.0.tgz
mv kafka_2.11-1.1.0.tgz kafka (修改檔案名)
step2 添加檔案夾
在kafka根目錄下添加檔案夾logs
mkdir logs
![](https://img.laitimes.com/img/9ZDMuAjOiMmIsIjOiQnIsISPrdEZwZ1Rh5WNXp1bwNjW1ZUba9VZwlHdsATOfd3bkFGazxCMx8VesATMfhHLlN3XnxCMwEzX0xiRGZkRGZ0Xy9GbvNGLpZTY1EmMZVDUSFTU4VFRR9Fd4VGdsYTMfVmepNHLrJXYtJXZ0F2dvwVZnFWbp1zczV2YvJHctM3cv1Ce-cmbw5SMwgjMjZWZyIDZxEGZwUjM3MzY2YjMlV2Y4ETNhRGM48CXzAzLclDMxIDMy8CXn9Gbi9CXzV2Zh1WavwVbvNmLvR3YxUjL4M3Lc9CX6MHc0RHaiojIsJye.png)
step3 修改配置檔案
進入解壓後的目錄,修改server.properties檔案:
vim/usr/local/kafka/config/server.properties
依次修改下面的内容:
broker.id=0 #根據伺服器情況修改值,可以為0,1,2...
port=9092 #端口号
host.name=192.168.24.128 #伺服器ip
advertised.host.name=192.168.24.128 #伺服器ip
log.dirs=/usr/local/kafka/logs #logs檔案路徑
num.partitions=2 #分區數量
zookeeper.connect=192.168.24.128:2181, 192.168.24.129:2181, 192.168.24.130:2181 #zookeeper伺服器url
step4 啟動kafka
首先啟動ZooKeeper:
zkServer.sh start
進入到kafka根目錄下:
cd /usr/local/kafka
啟動kafka:
bin/kafka-server-start.sh config/server.properties &
下面的是broker為1的啟動結果:
step5 檢驗是否啟動成功
jps
OK,GAME OVER!
更多内容,請關注公衆号:程式員高手之路