[發(fā)明專利]基于Linux系統(tǒng)的kafka集群自動部署方法和裝置

在審

• 申請?zhí)枺?/td>: 201711241022.7
• 申請日: 2017-11-30
• 公開（公告）號: CN108073402A
• 公開（公告）日: 2018-05-25
• 發(fā)明（設(shè)計）人: 張忠德;趙連睿;王震;王東寧;鄧貞翔
• 申請（專利權(quán)）人: 山東魯能軟件技術(shù)有限公司
• 主分類號: G06F8/60
• 分類號: G06F8/60;G06F8/71;H04L29/08
• 代理公司: 濟南圣達知識產(chǎn)權(quán)代理有限公司 37221
• 代理人: 黃海麗

1.一種基于Linux系統(tǒng)的kafka集群自動部署方法，預(yù)先將kafka和zookeeper安裝介質(zhì)上傳到本地，其特征在于，包括以下步驟：

步驟1：讀取并解析配置文件，獲取kafka集群的節(jié)點信息和配置信息；

步驟2：根據(jù)kafka集群的節(jié)點信息將所述安裝介質(zhì)分發(fā)到集群中的各個節(jié)點；

步驟3：根據(jù)配置信息，遠程登錄到各個節(jié)點相應(yīng)的目標主機修改配置文件，通過運行腳本依次啟動zookeeper服務(wù)和kafka服務(wù)。

2.如權(quán)利要求1所述的kafka集群自動部署方法，其特征在于，所述節(jié)點信息包括：kafka集群各個節(jié)點的網(wǎng)絡(luò)地址和安裝路徑。

3.如權(quán)利要求1所述的kafka集群自動部署方法，其特征在于，所述配置信息包括kafka配置信息和zookeeper配置信息，其中，所述kafka配置信息包括節(jié)點標識id，節(jié)點主機名，端口號，消息存放的目錄，默認分區(qū)數(shù)，zookeeper集群地址；所述zookeeper配置信息包括節(jié)點ip地址，端口號，日志目錄，心跳時間。

4.如權(quán)利要求1所述的kafka集群自動部署方法，其特征在于，所述步驟2和3是通過調(diào)用自動部署模塊實現(xiàn)的。

5.如權(quán)利要求1所述的kafka集群自動部署方法，其特征在于，將安裝介質(zhì)分發(fā)到集群中的各個節(jié)點后，還并發(fā)自動解壓各個節(jié)點上的安裝介質(zhì)。

6.如權(quán)利要求1所述的kafka集群自動部署方法，其特征在于，修改配置文件是并發(fā)自動修改。

7.一種基于Linux系統(tǒng)的kafka集群自動部署裝置，包括存儲器和處理器，存儲器上存儲有預(yù)先上傳的kafka和zookeeper安裝介質(zhì)，以及可在處理器上運行的計算機程序，其特征在于，所述處理器執(zhí)行所述程序時實現(xiàn)以下步驟：

步驟1：讀取并解析配置文件，獲取kafka集群的節(jié)點信息和配置信息；

步驟2：根據(jù)kafka集群的節(jié)點信息將所述安裝介質(zhì)分發(fā)到集群中的各個節(jié)點；

步驟3：根據(jù)配置信息，遠程登錄到各個節(jié)點相應(yīng)的目標主機修改配置文件，通過運行腳本依次啟動zookeeper服務(wù)和kafka服務(wù)。

8.一種計算機可讀存儲介質(zhì)，其上存儲有計算機程序，其特征在于，該程序被處理器執(zhí)行時執(zhí)行以下步驟：

步驟1：讀取并解析配置文件，獲取kafka集群的節(jié)點信息和配置信息；

步驟2：根據(jù)kafka集群的節(jié)點信息將本地服務(wù)器的zookeeper和kafka安裝介質(zhì)分發(fā)到集群中的各個節(jié)點；

步驟3：根據(jù)配置信息，遠程登錄到各個節(jié)點相應(yīng)的目標主機修改配置文件，通過運行腳本依次啟動zookeeper服務(wù)和kafka服務(wù)。