Windows如何安裝運行Apache Kafka

這篇文章主要介紹了Windows如何安裝運行Apache Kafka，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

下載所需文件

• 根據系統OS和CPU架構，在這里下載Server JRE http://www.oracle.com/technetwork/java/javase/downloads/jre8-downloads-2133155.html

• 在這里下載并安裝7-zip http://www.7-zip.org/download.html

• 在這里下載Zookeeper，并用7-zip解壓 http://zookeeper.apache.org/releases.html

• 在這里下載Kafka并用7-zip解壓 http://kafka.apache.org/downloads.html

針對此教程，我們將Zookeeper與Kafka解壓到C盤，不過也可以選擇其他位置。這里我們要使用完全的zookeeper，而不是用Kafka打包的那個，因為這是一個單節點的Zookeeper實例。也可以運行打包了zookeeper的Kafka，位置在\kafka\bin\windows庫中。

安裝

A. JDK安裝

1.啟動JRE安裝，選中復選框“修改目標路徑”，然后點擊安裝。

2.修改安裝目錄，文件夾名稱中不能有空格，例如：C:\Java\jre1.8.0_xx\（默認情況下是C:\Program Files\Java\jre1.8.0_xx），然后點擊下一步。 
3.現在點擊控制面板->系統->高級系統設置->環境變量，打開系統環境變量對話框。 
4.點擊用戶變量中的新用戶變量按鈕，然后在變量名稱那里輸入JAVA_HOME，并將自定義的jre路徑填入變量值。如下圖所示：

8.確認Java安裝打開cmd，輸入類型“java –version”，應該能夠看到剛剛安裝的java版本。

恭喜，Zookeeper已經完成并在端口2181運行。

C. 安裝Kafka

1. 進入Kafka配置目錄，例如C:\kafka_2.11-0.9.0.0\config 
2. 編輯文件“server.properties” 
3. 找到并編輯“log.dirs=/tmp/kafka-logs” to “log.dir= C:\kafka_2.11-0.9.0.0\kafka-logs” 
4. 如果Zookeeper在某些其他的機器或集群上運行，可以將“zookeeper.connect:2181”修改為自定義IP與端口。在這個演示中我們使用了同一個機器，因此沒必要做修改。文件中的Kafka端口和broker.id也是可以配置的。其他設置不變。 
5. Kafka會按照默認，在9092端口上運行，并連接zookeeper的默認端口：2181。

D. 運行Kafka服務器

重要：請確保在啟動Kafka服務器前，Zookeeper實例已經準備好并開始運行。

1.進入Kafka安裝目錄C:\kafka_2.11-0.9.0.0\ 
2.按下Shift+右鍵，選擇“打開命令窗口”選項，打開命令行。 
3.現在輸入.\bin\windows\kafka-server-start.bat .\config\server.properties 并回車。

.\bin\windows\kafka-server-start.bat .\config\server.properties

5.現在Kafka已經準備好并開始運行，可以創建主題來存儲消息了。我們也能從Java/Scala代碼中，或直接從命令行中生成或使用數據。

E. 創建主題

1. 現在創建主題，命名為“test”，replication factor=1（因為只有1個Kafka服務器在運行）。如果集群中所運行的Kafka服務器不止1個，可以相應增加replication-factor，從而提高數據可用性和系統容錯性。 
2. 在C:\kafka_2.11-0.9.0.0\bin\windows打開新的命令行。 
3. 輸入下面的命令，回車：

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

6.在producer命令行中任意輸入內容，回車；在其他consumer命令行中能看到相應消息。

7.如果能夠將消息推送到consumer端并顯示出來的話，Kafka安裝就完成了。

一些有用的命令：

cd /home/work/soft/kafka_2.8.0-0.8.1.1/bin

./kafka-topics.sh --create --zookeeper 10.48.170.26:2181 --replication-factor 1 --partitions 3 --topic test          
./kafka-console-producer.sh --broker-list 10.48.170.26:9092 --topic test
./kafka-console-consumer.sh --zookeeper 10.48.170.26:2181 --topic test

1.列出主題：./kafka-topics.sh --list --zookeeper 10.48.170.26:2181 
2.描述主題：./kafka-topics.sh --describe --zookeeper 10.48.170.26:2181 --topic [Topic Name] 
3.從頭讀取消息：./kafka-console-consumer.sh --zookeeper 10.48.170.26:2181 --topic [Topic Name] --from-beginning 
4.刪除主題：./kafka-run-class.sh kafka.admin.TopicCommand --delete --topic [topic_to_delete] --zookeeper 10.48.170.26:2181

感謝你能夠認真閱讀完這篇文章，希望小編分享的“Windows如何安裝運行Apache Kafka”這篇文章對大家有幫助，同時也希望大家多多支持億速云，關注億速云行業資訊頻道，更多相關知識等著你來學習!