首先準備至少三臺虛擬機。

每臺虛擬機解壓下載好的kafka壓縮包并重命名

cd /usr/local

wget http://mirror.bit.edu.cn/apache/kafka/1.0.0/kafka_2.11-1.0.0.tgz?

tar -zxvf kafka_2.11-1.0.0.tgz

mv kafka_2.12-0.11.0.0 kafka

修改配置文件

vim? ?./kafka/config/server.properties

修改的內容如下

broker.id為kafka節點。listeners=PLAINTEXT為本機的ip地址，9092為kafka的默認端口號。zookeeper.connect為zookeeper的地址。

每臺服務器上面的broker.id和listeners不一樣，zookeeper.connect都是一樣的。

broker.id=0
listeners=PLAINTEXT://192.168.10.XX:9092
zookeeper.connect=192.168. 10.XX:2181,192.168. 10.XX:2181,192.168. 10.XX:2181

broker.id=1
listeners=PLAINTEXT://192.168.10.XX:9092
zookeeper.connect=192.168. 10.XX:2181,192.168. 10.XX:2181,192.168. 10.XX:2181?

broker.id=0
listeners=PLAINTEXT://192.168.10.XX:9092
zookeeper.connect=192.168. 10.XX:2181,192.168. 10.XX:2181,192.168. 10.XX:2181?

?啟動之前 和zookeeper一樣先刪除日志中的log。

啟動kafka

./kafka-server-start.sh ../config/server.properties >1.log &

?

總結

以上是生活随笔為你收集整理的Kafka集群环境搭建的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。