這篇文章將介紹如何搭建kafka環境，我們會從單機版開始，然后逐漸往分布式擴展。單機版的搭建官網上就有，比較容易實現，這里我就簡單介紹下即可，而分布式的搭建官網卻沒有描述，我們最終的目的還是用分布式來解決問題，所以這部分會是重點。

Kafka的中文文檔并不多，所以我們盡量詳細點兒寫。要交會你搭建分布式其實很簡單，手把手的教程大不了我錄個視頻就好了，可我覺得那不是走這條路的方 式。只有真正了解原理，并且理解的透徹了才能最大限度的發揮一個框架的作用。所以，如果你不了解什么事kafka，請先看：《kafka初步》

我們從搭建單機版的環境開始說起,如果你喜歡看英文版：這里有官方的《quick start》

單機版的部署很簡單，我就講幾點比較重要的，首先kafka是用scala編寫的，可以跑在JVM上，所以我們并不需要單獨去搭建scala的環境，后面會涉及到編程的時候我們再說如何去配置scala的問題，這里用不到，當然你要知道這個是跑在linux上的。第二，我用的是最新版0.7.2的版本，你下載完kafka你可以打開它的目錄瀏覽一下：

我就不介紹每個包里的內容是干嘛的，我就著重說一點，你在這個文件夾里只能找到3個jar包，并且這3個還不能用于后面的編程，而且你也沒法在里面找到pom這樣用于構建的xml。也別急，也別滿世界找，這些依賴庫得等你把它放到linux上才會出現（當然需要命令）。

搭建單機版環境，簡單的說有那么幾步：

1. 安裝java環境，我用的是最新的版本jdk7的

2. 將下載下來的kafka扔到linux上，并解壓。我用的red het server的linux。

3. 接下來就是下載kafka的依賴包和構建kafka的環境。注意，這一步需要電腦聯網。具體命令就是官網介紹的./sbt update 和 ./sbt package。

4.  執行完上面這步大概會花個10多分鐘吧，我在自己家里ubuntu沒有成功，報了下載不到jline的錯。單位里用虛擬機ubuntu成功了，我深刻懷疑是網的問題。上面這不執行完了有兩點要注意，一是sbt幫你下載完了所有依賴庫，但是這些jar都是分散在各個目錄下的，注意區分。二是，這些jar一部分是kafka的編程包，一部分是scala的環境包，上面說了沒必要自己去搭scala的環境道理就在這邊，你自己去下一個2.9的scala，但人家kafka只支持2.8、2.7。所以編程的時候就用sbt給你下好的包即可。后面講到編程的時候，會寫怎么搭編程環境，很簡單的。

上面的步驟都執行完了，環境算是好了，下面我們要測試下是否能成功運行kafka：

1.   啟動zookeeper server ：bin/zookeeper-server-start.sh ../config/zookeeper.properties  & (用&是為了能退出命令行)

2.    啟動kafka server:  bin/kafka-server-start.sh ../config/server.properties  &

3.    Kafka為我們提供了一個console來做連通性測試，下面我們先運行producer：bin/kafka-console-producer.sh --zookeeper localhost:2181 --topic test 這是相當于開啟了一個producer的命令行。命令行的參數我們一會兒再解釋。

4.    接下來運行consumer，新啟一個terminal：bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

5.    執行完consumer的命令后，你可以在producer的terminal中輸入信息，馬上在consumer的terminal中就會出現你輸的信息。有點兒像一個通信客戶端。

具體可看《quick start》

如果你能看到5執行了，說明你單機版部署成功了。下面解釋下兩條命令中參數的意思。--zookeeper localhost:2181 這個說明了去連本機2181端口的zookeeper server，--topic test，在kafka里，消息按topic來區分，我們這里的topic叫test，所以不管是consumer還是producer都指向了test。其他的參數，我就截圖了，首先是producer的參數：

Consumer的參數:

這些參數你可以先看個大概，之后會在編程中使用到，都可以動態的配置。

好了單機版就部署完了，那是不是我把consumer的放到另一臺機器上就算分布式了呢。是的，前提是，你還能運行到上面的第5步。在講配置之前,我們還是將上篇寫的分布式來回顧一下，當然我們簡化一下情況，按照實際部署的分析：

假設我只有兩臺機器，server1和server2。我現在想把zookeeper server和kafka server 和producer都放在一臺機器上server1，把consumer放在server2上。這當然也叫分布式了，雖然機子不多，但是這個部署成功了，擴展是相當的容易。

我們還是按照那5個步驟來做，當然你肯定能知道，3、4兩步的參數要改了，我們假設server1的IP是192.168.10.11 server2的IP是192.168.10.10：

1.  啟動zookeeper server ：bin/zookeeper-server-start.sh ../config/zookeeper.properties  & (用&是為了能退出命令行)

2.  啟動kafka server:  bin/kafka-server-start.sh ../config/server.properties  &

3.   Kafka為我們提供了一個console來做連通性測試，下面我們先運行producer：bin/kafka-console-producer.sh --zookeeper 192.168.10.11:2181 --topic test 這是相當于開啟了一個producer的命令行。

4.   接下來運行consumer，新啟一個terminal：bin/kafka-console-consumer.sh --zookeeper 192.168.10.11:2181 --topic test --from-beginning

5.   執行完consumer的命令后，你可以在producer的terminal中輸入信息，馬上在consumer的terminal中就會出現你輸的信息。

這個時候你能執行出第5步的效果么，是不是報了下面的錯了：

我來說原因，在這之前想請你再回去看看《kafka初步》，看看里面講分布式的內容：

這里的kafka server就是broker，broker是存數據的，producer把數據給broker，consumer從broker取數據。那zookeeper是干嘛的，說的膚淺點兒，zookeeper就是他們之間的選擇分發器，所有的連接都要先注冊到zookeeper上。你可以把它想象成NIO，zookeeper就是selector，producer、consumer和broker都要注冊到selector上，并且留下了相應的key。

所以問題就出在了kafka server的配置server.properties上。Kafka注冊到zookeeper上的信息不對，才導致了上面的錯誤。我們看config中server.properties的配置就可以知道：

# Hostname the broker will advertise to consumers. If not set, kafka will use the value returned

from InetAddress.getLocalHost().  If there are multiple interfaces getLocalHost
may not be what you want.
hostname=</pre></div>
</div>
默認的hostname如果你不設置，就是127.0.0.1，所以你把這個hostname設置成192.168.10.11即可，這樣你重啟下kafka server端，就能執行第5步了。 

成功配置的話，你能看到下面的效果，左邊的是producer，右邊的是consumer，看最下面兩行好了，前面的是我之前測試用過的： 

 


如果你還是云里霧里的，建議你回頭去看看上篇文章，將kafka分布式基本原理的，kafka實際操作是要建立在對原理熟悉的情況下的。 
搭建完了環境，后面就要開始寫程序去處理實際問題了。當然再寫程序之前，下一篇我會先寫一點 kafka為什么會有如此高的性能，它是怎么保障這些性能的。