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


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下的消息並打印到標准輸出。打開新的終端。執行如下命令。

 

待續......


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM