kafka單節點的安裝，部署，使用

一、kafka官網：http://kafka.apache.org/downloads

jdk：https://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html

參考書籍：Apache kafka實戰

下載安裝以下所示：

我下載的是kafka_2.11-2.1.0

而後點擊以下進行下載便可：

 下載jdk,根據本身的需求下載所需的jdk版本，64位仍是32位的。我下載的32位的jdk-8u191-linux-i586.tar.gz。

 而後將下載好的jdk-8u191-linux-i586.tar.gz和kafka_2.11-2.1.0.tgz傳輸到本身的機器上面，找個特定的目錄，這樣方便本身進行管理。

二、而後將jdk-8u191-linux-i586.tar.gz和kafka_2.11-2.1.0.tgz。解壓縮到特定的目錄裏面，方便管理。

配置jdk的環境變量：

三、啓動服務器，配置好jdk和kafka就能夠啓動了，啓動以前要先啓動zookeeper服務器，zookeeper是爲kafka提升協調服務的工具。kafka已經內置了一個zookeeper服務器以及一些啓動腳本。

 

啓動好zookeeper之後，而後啓動kafka服務器。

 [KafkaServer id=0] started (kafka.server.KafkaServer)說明kafka服務器啓動成功，默認的服務端口是9092。

四、建立topic，服務器啓動後，咱們須要建立一個主題（topic）用於消息的發送和接受。這一步將建立一個名稱爲test的topic，該topic只有一個分區（partition）,且該partition也只有一個副本（replica）處理消息。

注意：爲了要建立topic，要保證剛纔啓動的zookeeper和kafka的終端不被關閉。打開一個新的終端。

 而後topic建立成功了，使用命令查看該topic的狀態。

 五、發送消息，即生產消息。kafka默認提供了腳本工具能夠不斷的接受標準輸入並將他們發送到kafka的某個topic上面，用戶在控制檯終端下啓動該命令，輸入一行文本數據，而後該腳本將改行文本封裝成一條kafka消息發送給指定的topic。打開新的終端，執行命令。

 六、消費消息，消費者，kafka提供了一對應的腳本用於消費某些topic下的消息並打印到標準輸出。打開新的終端。執行以下命令。

 

待續......