Kafka叢集安裝指南

該文件是建立在已經安裝好JAVA JDK的基礎上，並且設定好$JAVA_HOME環境變數。

一、  Kafka安裝

1.     解壓kafka安裝包

執行 tar  -zxvf  kafka_2.9.2-0.8.1.1.tgz

2.        配置kafka

配置環境變數 KAFKA_HOME

分別在叢集機器上配置$KAFKA_HOME/config/server.properties

broker.id=0 （每個叢集機器標識唯一）

listeners=PLAINTEXT://192.168.1.54:9092 （每個機器對應IP）

log.dirs=/opt/huawei/imax/kafka/log 

zookeeper.connect=zk1:2181,zk2:2181,zk3:2181   (zookeeper 安裝機器)

備註：這裡kafka依賴於Zookeeper的環境進行資料一致性管理，這裡使用的Zookeeper是外部安裝配置，沒有使用kafka內建的。

3.        啟動kafka服務

在各個叢集機器上執行

$KAFKA_HOME/bin/kafka-server-start.sh$KAFKA_HOME/config/server.properties &

4.        驗證安裝是否成功

a)        JPS檢視程序是否存在Kafka

b)       新建一個topic是否成功

$KAFKA_HOME/bin/kafka-topics.sh--create --topic test --replication-factor 3 --partitions 1 --zookeeperzk1:2181