Kafka 快速安裝與使用
這篇文章是一篇Ubuntu(Linux)環(huán)境下的Kafka安裝與使用教程,通過本文,你可以非常快速搭建一個kafka的小單元進行日常開發(fā)與調(diào)測。
安裝步驟
1. 下載與解壓安裝
首先我們需要下載一下Kafka的安裝包,這里筆者采用的是通用的wget指令:
wget https://downloads.apache.org/kafka/3.9.0/kafka_2.13-3.9.0.tgz
完成下載后將項目解壓與重命名,方便后續(xù)的使用:
tar -xzf kafka_2.13-3.9.0.tgz
mv kafka_2.13-3.9.0 kafka
2. 基本配置
因為筆者是在windows下的Linux子系統(tǒng),為保證宿主機和子系統(tǒng)內(nèi)部的Kafka可以準確連通,需打開config/server.properties文件,將ip改為你的對應(yīng)主機IP確保以監(jiān)聽正確的網(wǎng)卡接受處理請求:
對應(yīng)的配置參數(shù)如下,筆者只需將參數(shù)改為自己的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服務(wù)端啟動即可:
./bin/kafka-server-start.sh config/server.properties
4. 生產(chǎn)者與消費者收發(fā)調(diào)測
經(jīng)過上述的基本配置之后,我們已經(jīng)成功的將kafka服務(wù)端啟動了,以本文為例筆者的消費者會訂閱transactions 這個topic,對應(yīng)的啟動指令為:
./bin/kafka-console-consumer.sh --bootstrap-server ip:9092 --topic 消費主題 --from-beginning
因為筆者服務(wù)器ip為172.19.182.7,且主題為transactions 所以對應(yīng)的執(zhí)行指令為:
./bin/kafka-console-consumer.sh --bootstrap-server 172.19.182.7:9092 --topic transactions --from-beginning
確認無誤后,啟動一個topic為transactions的生產(chǎn)者投遞消息,對應(yīng)啟動指令如下:
./bin/kafka-console-producer.sh --broker-list 172.19.182.7:9092 --topic transactions
隨后我們在生產(chǎn)者控制臺鍵入hello consumer:
>hello consumer
如下圖,如果消費者接收消息成功,則說明本次kafka的基本配置與部署完成: