Kafka 快速安裝與使用
這篇文章是一篇Ubuntu(Linux)環境下的Kafka安裝與使用教程,通過本文,你可以非常快速搭建一個kafka的小單元進行日常開發與調測。
安裝步驟
1. 下載與解壓安裝
首先我們需要下載一下Kafka的安裝包,這里筆者采用的是通用的wget指令:
wget https://downloads.apache.org/kafka/3.9.0/kafka_2.13-3.9.0.tgz
完成下載后將項目解壓與重命名,方便后續的使用:
tar -xzf kafka_2.13-3.9.0.tgz
mv kafka_2.13-3.9.0 kafka
2. 基本配置
因為筆者是在windows下的Linux子系統,為保證宿主機和子系統內部的Kafka可以準確連通,需打開config/server.properties文件,將ip改為你的對應主機IP確保以監聽正確的網卡接受處理請求:
對應的配置參數如下,筆者只需將參數改為自己的ip地址即可:
listeners=PLAINTEXT://x.x.x.x:9092
advertised.listeners=PLAINTEXT://x.x.x.x:9092
3. 啟動測試
完成上述步驟之后,鍵入如下指令即通過bin目錄的zookeeper-server-start.sh將注冊中心zookeeper啟動,觀測控制臺啟動是否無誤,無誤之后可以嘗試后臺啟動,這里筆者為了文章的精簡就不做過多演示了:
./bin/zookeeper-server-start.sh config/zookeeper.properties
如下圖,成功綁定2181后即可說明zk啟動成功了:
同理將Kafka服務端啟動即可:
./bin/kafka-server-start.sh config/server.properties
4. 生產者與消費者收發調測
經過上述的基本配置之后,我們已經成功的將kafka服務端啟動了,以本文為例筆者的消費者會訂閱transactions 這個topic,對應的啟動指令為:
./bin/kafka-console-consumer.sh --bootstrap-server ip:9092 --topic 消費主題 --from-beginning
因為筆者服務器ip為172.19.182.7,且主題為transactions 所以對應的執行指令為:
./bin/kafka-console-consumer.sh --bootstrap-server 172.19.182.7:9092 --topic transactions --from-beginning
確認無誤后,啟動一個topic為transactions的生產者投遞消息,對應啟動指令如下:
./bin/kafka-console-producer.sh --broker-list 172.19.182.7:9092 --topic transactions
隨后我們在生產者控制臺鍵入hello consumer:
>hello consumer
如下圖,如果消費者接收消息成功,則說明本次kafka的基本配置與部署完成: