Kafka 集群 Golang 應用例項

2021-09-12 15:47:30 字數 517 閱讀 5072

專案見:?

kafka cluster example

這個例項做了些什麼?

搭建了擁有 3 節點 kafka、 3 節點 zookeeper 的 docker 集群服務;

分別建立了 1 個訊息發布者和 2 個相同消費組的訊息訂閱者的 docker 應用;

使用ab進行併發測試,驗證該例項訊息的訂閱 / 發布功能;

通過這個例項,能夠了解些什麼?

使用 docker compose 構建 kafka 集群

使用 golang 建立 kafka pub/sub 例項

使用 apachebench 進行併發測試

使用 makefile 簡化構建操作命令

如果這個例項,對你了解 kakfa 有所幫助,請為專案新增 star ,非常感謝!

zookeeper集群部署 kafka集群部署

wget wget 解壓到目錄 tar zxvf apache zookeeper 3.5.8 bin.tar.gz c usr local 進入目錄 cd usr local 建立軟連線 ln s usr local apache zookeeper 3.5.8 zookeeper 複製配置檔案 ...

kafka 集群 測試

參考資料 wget 解壓tar xvzf kafka 2.11 0.10.0.1.tgz 移動mv kafka 2.11 0.10.0.1 usr local 修改配置 cd kafka 2.11 0.10.0.1 config mv server.properties server 1.prope...

kafka集群搭建

安裝zookeeper kafka自帶了zookeeper,建議還是用外部的zk集群,搭建步驟如下 準備3臺機器,假設我們叫c1 c2 c3,ip分別為ip1 ip2 ip3 將附件zookeeper 3.4.6.tar.gz分別拷貝至3臺機器 c1機器上解壓zookeeper 3.4.6.tar....