文章目錄
在 CentOS 上使用 Kafkacat
原文做法已失敗,請參考 在 CentOS 上使用 Kafkacat (更新) : 使用 container (更新版)
之前筆記 在CentOS 上安裝 Apache Kafka cluster 與 在 CentOS 上安裝 Apache Kafka cluster - One Script 都紀錄到如何在 CentOS 上安裝 Apache Kafka,不過順利安裝與成功安裝還是存在差異的,過去我都是直接透過 Kafka 內建的 cli 工具來進行驗證不需要額外下載安裝其他工具,只是最近搭配 Kubernetes 使用時常會有需要確認連線的情境,這時候再下載完整的 Kafka 似乎顯得多餘,今天就來紀錄一下如何在 CentOS 上使用 Kafkacat
Kafkacat 是由 c 語言開發的 Kafka client,不需要 Java,非常輕巧,在 debian、Ubuntu 可以使用 apt-get install kafkacat
進行安裝,而 macOS 上可以透過 brew install kafkacat
安裝,而對於 centOS 就沒那麼 friendly 了,這也是今天會紀錄的原因
基本環境說明
- Linux (centos 7.7.1908)
- librdkafka 0.11.4-1.el7
安裝 kafkacat
安裝 gcc-c++,git 與 librdkafka
yum update -y && yum install gcc-c++ git librdkafka-devel -y
下載 kafkacat
git clone https://github.com/edenhill/kafkacat
設定 config
cd kafkacat && ././configure
編譯並安裝
make && make install
實際使用
producer
以下語法會讓 producer 持續監聽 stdin 來傳送 message
kafkacat -P -b node3:9092 -t test
consumer
以下語法會讓 consumer 持續監聽並透過 stdout 來輸出收到的 message
kafkacat -b node3:9092 -t test
心得
不知道為什麼 kafkacat 沒有加入 yum 中,我一度想要在 CentOS 中安裝 apt-get,只是找了些資料後發現相關安裝方法似乎都過期不適用了(我不是十分確定,有錯請指教),於是最後選擇透過編譯原始碼的方式來處理,只是這麼一來(額外安裝了編譯器)是否有比下載 kafka (想要使用內建的 cli)來得輕巧就說不準了,但還是紀錄一下方便自己查閱,也讓網路上的諸方高手批評指教
參考資訊
文章作者 Yowko Tsai
上次更新 2022-09-02
授權合約
本部落格 (Yowko's Notes) 所有的文章內容(包含圖片),任何轉載行為,必須通知並獲本部落格作者 (Yowko Tsai) 的同意始得轉載,且轉載皆須註明出處與作者。
Yowko's Notes 由 Yowko Tsai 製作,以創用CC 姓名標示-非商業性-相同方式分享 3.0 台灣 授權條款 釋出。