本篇內(nèi)容介紹了“Centos7如何編譯安裝kafka-manager”的有關(guān)知識(shí),在實(shí)際案例的操作過(guò)程中,不少人都會(huì)遇到這樣的困境,接下來(lái)就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧!希望大家仔細(xì)閱讀,能夠?qū)W有所成!
本篇內(nèi)容介紹了“Centos7如何編譯安裝kafka-manager”的有關(guān)知識(shí),在實(shí)際案例的操作過(guò)程中,不少人都會(huì)遇到這樣的困境,接下來(lái)就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧!希望大家仔細(xì)閱讀,能夠?qū)W有所成!管理多個(gè)集群
創(chuàng)新互聯(lián)公司是一家集網(wǎng)站建設(shè),花溪企業(yè)網(wǎng)站建設(shè),花溪品牌網(wǎng)站建設(shè),網(wǎng)站定制,花溪網(wǎng)站建設(shè)報(bào)價(jià),網(wǎng)絡(luò)營(yíng)銷,網(wǎng)絡(luò)優(yōu)化,花溪網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè),幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競(jìng)爭(zhēng)力??沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時(shí)我們時(shí)刻保持專業(yè)、時(shí)尚、前沿,時(shí)刻以成就客戶成長(zhǎng)自我,堅(jiān)持不斷學(xué)習(xí)、思考、沉淀、凈化自己,讓我們?yōu)楦嗟钠髽I(yè)打造出實(shí)用型網(wǎng)站。
具體支持以下內(nèi)容
輕松檢查群集狀態(tài)(主題,消費(fèi)者,偏移,代理,副本分發(fā),分區(qū)分發(fā))
運(yùn)行首選副本選舉
使用選項(xiàng)生成分區(qū)分配以選擇要使用的代理
運(yùn)行分區(qū)重新分配(基于生成的分配)
使用可選主題配置創(chuàng)建主題(0.8.1.1具有與0.8.2+不同的配置)
刪除主題(僅支持0.8.2+并記住在代理配置中設(shè)置delete.topic.enable = true)
主題列表現(xiàn)在指示標(biāo)記為刪除的主題(僅支持0.8.2+)
批量生成多個(gè)主題的分區(qū)分配,并可選擇要使用的代理
批量運(yùn)行重新分配多個(gè)主題的分區(qū)
將分區(qū)添加到現(xiàn)有主題
更新現(xiàn)有主題的配置
支持ldap用戶認(rèn)證
kafka-manager 項(xiàng)目地址:https://github.com/yahoo/kafka-manager
安裝
當(dāng)前版本已更新至3.0.0.1,本次安裝最新版本。
下載源碼包:https://github.com/yahoo/kafka-manager/releases (不同版本)
克隆源代碼:git clone https://github.com/yahoo/CMAK.git (最新版本)
編譯
根據(jù)README提示,新版本編譯依賴java-11,所以首先要準(zhǔn)備java-11環(huán)境(直接到官網(wǎng)下載解壓即可)。
使用sbt編譯
進(jìn)入源碼目錄進(jìn)行編譯。/path/to/cmak/sbt -java-home /path/to/java-11 clean dist
-java-home:在系統(tǒng)環(huán)境java版本和當(dāng)前需要java版本不一致時(shí),使用該參數(shù)指定java家目錄。
這是一個(gè)漫長(zhǎng)的過(guò)程,耐心等待...
編譯完成后會(huì)提示,編譯好的文件保存到了:/path/to/cmak/target/universal/cmak-3.0.0.1.zip
配置
將上述cmak-3.0.0.1.zip文件拷貝到/path/to/kafka-manager 目錄下,解壓。修改配置文件 conf/application.conf:kafka-manager.zkhosts="my.zookeeper.host.com:2181,other.zookeeper.host.com:2181"cmak.zkhosts="my.zookeeper.host.com:2181,other.zookeeper.host.com:2181"
kafka-manager支持ldap認(rèn)證,這里不做詳述。
啟動(dòng)
默認(rèn)使用9000端口,如果端口占用,可以指定端口。bin/cmak -Dconfig.file=conf/application.conf -java-home /path/to/jdk-11 -Dhttp.port=9001
到瀏覽器訪問(wèn) http://ip:9001 即可。
創(chuàng)建kafka集群
使用systemctl管理kafka-manager服務(wù)
創(chuàng)建文件 /usr/lib/systemd/system/kafka-manager.service :[Unit]Description=kafka-manager server serviceAfter=network.target[Service]WorkingDirectory=/path/to/kafka-manager/cmak-3.0.0.1ExecStart=/path/to/kafka-manager/cmak-3.0.0.1/bin/cmak -Dconfig.file=/path/to/kafka-manager/cmak-3.0.0.1/conf/application.conf -java-home /path/to/jdk-11.0.6 -Dhttp.port=9001Restart=on-failureRestartSec=60User=workGroup=work[Install]WantedBy=multi-user.target
完成上述配置后,執(zhí)行 systemctl daemon-reload 。
啟動(dòng)、停止、重啟$ systemctl start kafka-manager$ systemctl stop kafka-manager$ systemctl restart kafka-manager
# 加入開(kāi)機(jī)啟動(dòng)$ systemctl enable kafka-manager
配置日志切割
/path/to/kafka-manager/cmak-3.0.0.1/logs/application.log { daily rotate 10 dateext missingok notifempty}