本篇內(nèi)容介紹了“Centos7如何編譯安裝kafka-manager”的有關(guān)知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠?qū)W有所成！

成都創(chuàng)新互聯(lián)公司主營企業(yè)營銷型網(wǎng)站建設，為眾多企業(yè)提供了品牌網(wǎng)站設計服務，建網(wǎng)站哪家好？擁有多年的全網(wǎng)營銷推廣流程，能夠為企業(yè)定制化制作網(wǎng)站服務，在公司網(wǎng)站建設維護方面成績突出。

管理多個集群具體支持以下內(nèi)容

輕松檢查群集狀態(tài)（主題，消費者，偏移，代理，副本分發(fā)，分區(qū)分發(fā)）

運行選副本選舉

使用選項生成分區(qū)分配以選擇要使用的代理

運行分區(qū)重新分配（基于生成的分配）

使用可選主題配置創(chuàng)建主題（0.8.1.1具有與0.8.2+不同的配置）

刪除主題（僅支持0.8.2+并記住在代理配置中設置delete.topic.enable = true）

主題列表現(xiàn)在指示標記為刪除的主題（僅支持0.8.2+）

批量生成多個主題的分區(qū)分配，并可選擇要使用的代理

批量運行重新分配多個主題的分區(qū)

將分區(qū)添加到現(xiàn)有主題

更新現(xiàn)有主題的配置

支持ldap用戶認證

kafka-manager 項目地址：https://github.com/yahoo/kafka-manager

安裝

當前版本已更新至3.0.0.1，本次安裝最新版本。

下載源碼包：https://github.com/yahoo/kafka-manager/releases (不同版本)

克隆源代碼：git clone /tupian/20230522/CMAK （最新版本）

編譯

根據(jù)README提示，新版本編譯依賴java-11，所以首先要準備java-11環(huán)境（直接到官網(wǎng)下載解壓即可）。

使用sbt編譯

進入源碼目錄進行編譯。

/path/to/cmak/sbt -java-home /path/to/java-11 clean dist

-java-home：在系統(tǒng)環(huán)境java版本和當前需要java版本不一致時，使用該參數(shù)指定java家目錄。

這是一個漫長的過程，耐心等待...

編譯完成后會提示，編譯好的文件保存到了：/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認證，這里不做詳述。

啟動

默認使用9000端口，如果端口占用，可以指定端口。

bin/cmak -Dconfig.file=conf/application.conf -java-home /path/to/jdk-11 -Dhttp.port=9001

到瀏覽器訪問 http://ip:9001 即可。

創(chuàng)建kafka集群

使用systemctl管理kafka-manager服務

創(chuàng)建文件 /usr/lib/systemd/system/kafka-manager.service ：

[Unit]
Description=kafka-manager server service
After=network.target
[Service]
WorkingDirectory=/path/to/kafka-manager/cmak-3.0.0.1
ExecStart=/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=9001
Restart=on-failure
RestartSec=60
User=work
Group=work
[Install]
WantedBy=multi-user.target

完成上述配置后，執(zhí)行 systemctl daemon-reload 。

啟動、停止、重啟

$ systemctl start kafka-manager
$ systemctl stop kafka-manager
$ systemctl restart kafka-manager

# 加入開機啟動

$ systemctl enable kafka-manager

配置日志切割

/path/to/kafka-manager/cmak-3.0.0.1/logs/application.log {
    daily
    rotate 10
    dateext
    missingok
    notifempty
}

“Centos7如何編譯安裝kafka-manager”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識可以關(guān)注創(chuàng)新互聯(lián)-成都網(wǎng)站建設公司網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實用文章！

標題名稱：Centos7如何編譯安裝kafka-manager-創(chuàng)新互聯(lián)
網(wǎng)頁網(wǎng)址：http://chinadenli.net/article46/dgpehg.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供營銷型網(wǎng)站建設、網(wǎng)站內(nèi)鏈、網(wǎng)站維護、做網(wǎng)站、定制網(wǎng)站、云服務器

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)