1、安裝java
注意:kafka 截止發稿日兼容最高版本為1.8 千萬不要安裝 更高版本 ,我就是安裝了12的發現不支持卸載了重裝的😂
這里提供一下下載地址吧,官網現在1.8的無法下載, https://download.csdn.net/download/chinayyj2010/11633015
安裝過程忽略,
2、驗證Java安裝
希望你已經在你的機器上安裝了java,所以你只需使用下面的命令驗證它。
java -version
java version "1.8.0_221" Java(TM) SE Runtime Environment (build 1.8.0_221-b11) Java HotSpot(TM) 64-Bit Server VM (build 25.221-b11, mixed mode)
3、使用brew 安裝kafka
打開終端輸入命令:
brew install kafka
如上圖,過程中會一直停了留在在 Updating Homebrew ... 此時可以執行ctrl + c 終止更新,繼續安裝。如圖結果。
至此已經完成了安裝,
安裝位置以及配置文件路徑都在圖片上顯示了,並且怎么啟動也都告訴了我們
安裝位置
/usr/local/Cellar/zookeeper
/usr/local/Cellar/kafka
配置文件位置
/usr/local/etc/kafka/server.properties
/usr/local/etc/kafka/zookeeper.properties
輸入啟動命令
kafka-server-start /usr/local/etc/kafka/server.properties
現在沒有出現報錯基本已經成功百分之90了,下面就是進行測試了
打開一個終端
#創建topic kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test #查看創建的topic kafka-topics --list --zookeeper localhost:2181 #終端1發送消息 kafka-console-producer --broker-list localhost:9092 --topic test
新開一個終端
#終端2接受消息
kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning
此時,在終端1中輸入信息,終端2會立即顯示在屏幕上面,如有結果輸出,即安裝成功
如下圖