Kafka 必須依賴 ZooKeeper，所以應該確保 ZooKeeper 已成功運行。Kafka 內置了 ZooKeeper，故如果未安裝 ZooKeeper可以使用其內置ZooKeeper。但我們一般使用外部 zookeeper 服務。 下載地址：http://kafka.apache.org/downloads 其中kafka_2.11-2.4.0表示 Kafka 版本 2.4.0，Scala 版本 2.11。 1. 上傳及解壓 ```shell [root@hadoop101 software]# tar -zxf kafka_2.11-0.11.0.2.gz -C /opt/install/ ``` 2. 創建軟連接和環境變量[可選] ```shell [root@hadoop101 install]# ln -s kafka_2.11-0.11.0.2 kafka ``` 3. 將kakfa添加到環境變量中 ```shell [root@hadoop101 install]# vim /etc/profile export KAFKA_HOME=/opt/install/kafka export PATH=$KAFKA_HOME/bin:$PATH -- 讓更改生效 [root@hadoop101 install]# source /etc/profile ``` 4. 修改{kafka_home}/config/server.properties ```properties [root@hadoop101 config]# vim server.properties # 要刪除topic是否真正刪除, 默認為false, 只是標記刪除,并沒有真正刪除, 實際開發環境中使用false delete.topic.enable=true # 設置日志[數據]的存儲位置, 默認是/tmp目錄下, 容易丟失 log.dirs=/opt/install/kafka/logs # 使用我們自己安裝的zookeeper # hadoop101:2181 對應自己機器的主機名:端口 zookeeper.connect=hadoop101:2181 # kafka服務器地址 listeners=PLAINTEXT://hadoop101:9092 ``` 5. 啟動kafka ```shell -- 如果把server.properties換成zookeeper.properties則是啟用kafka內置的zookeeper -- 啟動Kafka前記得先啟動Zookeeper -- 啟動方式1：后臺運行 [root@hadoop101 kafka]# bin/kafka-server-start.sh config/server.properties -- 啟動方式2：守護進程啟動 [root@hadoop101 kafka]# bin/kafka-server-start.sh -daemon config/server.properties [root@hadoop101 kafka]# jps 3555 Kafka 3622 Jps -- 關閉kafka的命令 [root@hadoop101 kafka]# bin/kafka-server-stop.sh ```