前言：

Strom從Kafka中讀取資料，本質是實現一個Storm中的Spout，來讀取Kafka中的資料；這個Spout，可以稱為Kafka Spout。支援兩種型別的Spout：

1. Core storm spout；

2. Trident spout；

部署：

1.安裝

下載kafka_2.11-0.8.2.2.tgz，上傳至叢集三個節點：node1，node2，node3（nimbus）的home/hadoop/app/目錄下，解壓，重新命名為kafka。

2.修改配置檔案

進入kafka配置目錄下，修改配置檔案zookeeper.properties、consumer.properties、producer.properties、server.properties

a.修改zookeeper.properties

b. 修改consumer.properties

c. 修改producer.properties

d. 修改server.properties

e. 分別修改node1、node2、node3上的server.properties(broker.id)為1，2，3。

3.啟動kafka叢集

在三臺機器上執行以下命令

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

4.測試叢集

a. 在node1上建立一個生產者（topic會自動生成）

[[email protected] kafka]$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

b. 在node3上建立一個消費者（topic和生產者的相同）

c. 在生產者上面輸入Hello，World

d. 可以看到消費者上面會輸出Hello，World

說明Kafka叢集搭建成功，後面就可以正常使用Kafka。