1、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傳輸到自己的機器上面,找個特定的目錄,這樣方便自己進行管理。
2、然后將jdk-8u191-linux-i586.tar.gz和kafka_2.11-2.1.0.tgz。解壓縮到特定的目錄里面,方便管理。
配置jdk的環境變量:
3、啟動服務器,配置好jdk和kafka就可以啟動了,啟動之前要先啟動zookeeper服務器,zookeeper是為kafka提高協調服務的工具。kafka已經內置了一個zookeeper服務器以及一些啟動腳本。
啟動好zookeeper以后,然后啟動kafka服務器。
[KafkaServer id=0] started (kafka.server.KafkaServer)說明kafka服務器啟動成功,默認的服務端口是9092。
4、創建topic,服務器啟動后,我們需要創建一個主題(topic)用於消息的發送和接受。這一步將創建一個名稱為test的topic,該topic只有一個分區(partition),且該partition也只有一個副本(replica)處理消息。
注意:為了要創建topic,要保證剛才啟動的zookeeper和kafka的終端不被關閉。打開一個新的終端。
然后topic創建成功了,使用命令查看該topic的狀態。
5、發送消息,即生產消息。kafka默認提供了腳本工具可以不斷的接受標准輸入並將他們發送到kafka的某個topic上面,用戶在控制台終端下啟動該命令,輸入一行文本數據,然后該腳本將改行文本封裝成一條kafka消息發送給指定的topic。打開新的終端,執行命令。
6、消費消息,消費者,kafka提供了一對應的腳本用於消費某些topic下的消息並打印到標准輸出。打開新的終端。執行如下命令。
待續......