[發(fā)明專利]一種云管理平臺上修改Kafka集群參數(shù)的方法在審
| 申請?zhí)枺?/td> | 202011587251.6 | 申請日: | 2020-12-28 |
| 公開(公告)號: | CN112667337A | 公開(公告)日: | 2021-04-16 |
| 發(fā)明(設(shè)計)人: | 程鋮 | 申請(專利權(quán))人: | 紫光云技術(shù)有限公司 |
| 主分類號: | G06F9/451 | 分類號: | G06F9/451 |
| 代理公司: | 天津濱海科緯知識產(chǎn)權(quán)代理有限公司 12211 | 代理人: | 劉瑩 |
| 地址: | 300459 天津市濱海新區(qū)*** | 國省代碼: | 天津;12 |
| 權(quán)利要求書: | 查看更多 | 說明書: | 查看更多 |
| 摘要: | |||
| 搜索關(guān)鍵詞: | 一種 管理 平臺 修改 kafka 集群 參數(shù) 方法 | ||
本發(fā)明提供了一種云管理平臺上修改Kafka集群參數(shù)的方法,包括如下步驟:S1、定義一個修改參數(shù)的接口,接口中添加一個可選參數(shù),名稱為“強(qiáng)制修改”;S2、用戶在UI界面上點擊修改參數(shù)接口,UI調(diào)用步驟S1中定義的接口,接口中不傳遞“強(qiáng)制修改”這個參數(shù);S3、接口接到請求后,按接口內(nèi)部邏輯進(jìn)行處理,如果沒有不正常狀態(tài)的機(jī)器,直接修改參數(shù),返回修改成功,本次操作結(jié)束,如果有不正常狀態(tài)的機(jī)器,返回修改失敗,提示狀態(tài)不正常。本發(fā)明所述的云管理平臺上修改Kafka集群參數(shù)的方法實現(xiàn)了在集群狀態(tài)不正常的情況下,讓用戶根據(jù)自己的實際情況,來決定是否修改集群的參數(shù)。
技術(shù)領(lǐng)域
本發(fā)明屬于云平臺資源管理技術(shù)領(lǐng)域,尤其是涉及一種云管理平臺上修改Kafka集群參數(shù)的方法。
背景技術(shù)
云服務(wù)平臺的上,會提供售賣Kafka中間件集群的服務(wù)給用戶,同時也會提供修改集群參數(shù)的功能。集群是由多臺機(jī)器組成,修改集群的參數(shù),實際上是修改每一臺機(jī)器的參數(shù),伴隨而來的就有一個問題,如果在修改參數(shù)的時候,集群中有一臺或者多臺機(jī)器處于故障狀態(tài),或者由于一些原因這些機(jī)器無法訪問到,那么是進(jìn)行修改操作呢,還是不修改呢?如果不修改,一般集群有幾臺機(jī)器故障也是不影響用戶使用的,不讓用戶修改參數(shù)不太合理,如果修改的話只能修改狀態(tài)正常機(jī)器的參數(shù),那么待故障機(jī)器修復(fù)后,就會出現(xiàn)一個集群中,有一部分機(jī)器參數(shù)不同步的問題。
這樣無論采用哪一種方案,都無法保證所有用戶都滿意。
現(xiàn)有的技術(shù)方案有下面兩種:
第一種,只有集群狀態(tài)都是正常的,才可以修改參數(shù),如果有一個或者多個機(jī)器不正常的就不容許修改。
第二種,修改參數(shù)的時候,只修改正常機(jī)器的狀態(tài),忽略狀態(tài)不正常的機(jī)器。
現(xiàn)有的技術(shù)方案存在以下幾點缺陷:
針對第一種方案,一般集群有幾臺機(jī)器故障也是不影響用戶使用的,不讓用戶修改參數(shù)不太合理。會有一部分用戶不滿意的。
針對第二種方案,修改參數(shù)的時候,只修改正常機(jī)器的狀態(tài),忽略狀態(tài)不正常的機(jī)器。這樣在故障機(jī)器恢復(fù)后,就造成了一個集群中,各個機(jī)器參數(shù)不一致的問題。可能會影響集群的正常使用,或者給用戶造成困惑,讓用戶不滿意。
發(fā)明內(nèi)容
有鑒于此,為克服上述缺陷,本發(fā)明旨在提出一種云管理平臺上修改Kafka集群參數(shù)的方法。
為達(dá)到上述目的,本發(fā)明的技術(shù)方案是這樣實現(xiàn)的:
一種云管理平臺上修改Kafka集群參數(shù)的方法,包括如下步驟:
S1、定義一個修改參數(shù)的接口,接口中添加一個可選參數(shù),名稱為“強(qiáng)制修改”;
S2、用戶在UI界面上點擊修改參數(shù)接口,UI調(diào)用步驟S1中定義的接口,接口中不傳遞“強(qiáng)制修改”這個參數(shù);
S3、接口接到請求后,按接口內(nèi)部邏輯進(jìn)行處理,如果沒有不正常狀態(tài)的機(jī)器,直接修改參數(shù),返回修改成功,本次操作結(jié)束,如果有不正常狀態(tài)的機(jī)器,返回修改失敗,提示狀態(tài)不正常。
所述步驟S1中,接口中的邏輯如下;
S101、如果沒有傳遞“強(qiáng)制修改”這個參數(shù),判斷每一個節(jié)點的狀態(tài),如果有一個不是正常狀態(tài),程序就結(jié)束,返回節(jié)點狀態(tài)不正常
S102、修改所有正常節(jié)點的參數(shù),忽略狀態(tài)不正常的節(jié)點。
進(jìn)一步的,所述步驟S3中,UI接到“修改成功”的結(jié)果后,給用戶提示修改成功,操作結(jié)束。
進(jìn)一步的,所述步驟S3中,UI接到“修改失敗,提示狀態(tài)不正常”的結(jié)果后,向用戶彈出提示“當(dāng)前集群有節(jié)點狀態(tài)不正常,是否僅修改正常節(jié)點的參數(shù)”;
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息,商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于紫光云技術(shù)有限公司,未經(jīng)紫光云技術(shù)有限公司許可,擅自商用是侵權(quán)行為。如果您想購買此專利、獲得商業(yè)授權(quán)和技術(shù)合作,請聯(lián)系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/202011587251.6/2.html,轉(zhuǎn)載請聲明來源鉆瓜專利網(wǎng)。
- Kafka集群的數(shù)據(jù)傳送方法和裝置
- KAFKA消息隊列數(shù)監(jiān)控方法、裝置、電子設(shè)備及存儲介質(zhì)
- KAFKA主題監(jiān)控方法、裝置、電子設(shè)備及存儲介質(zhì)
- 基于容器的集群遷移方法及裝置
- kafka消息的測試方法、裝置、計算機(jī)設(shè)備及存儲介質(zhì)
- 基于kafka集群的數(shù)據(jù)寫入方法、裝置、電子設(shè)備、存儲介質(zhì)
- 一種可視化部署并管理kafka集群的方法
- kafka消息存儲系統(tǒng)、方法、裝置及計算機(jī)可讀存儲介質(zhì)
- 一種基于kafka-connect的數(shù)據(jù)傳遞方法
- 一種將Kafka長連接消費轉(zhuǎn)換成服務(wù)的方法





