一種基于KAFKA的VPC配置下發(fā)方法

基本信息

申請?zhí)?/td> CN202111613233.5 申請日 -
公開（公告）號 CN114546584A 公開（公告）日 2022-05-27
申請公布號 CN114546584A 申請公布日 2022-05-27
分類號 G06F9/455（2006.01）I;H04L41/0803（2022.01）I;H04L41/0823（2022.01）I 分類 計算；推算；計數(shù);
發(fā)明人 楊志鵬 申請（專利權(quán)）人 紫光云（南京）數(shù)字技術(shù)有限公司
代理機(jī)構(gòu) 南京禾易知識產(chǎn)權(quán)代理有限公司 代理人 -
地址 211899江蘇省南京市浦口區(qū)江浦街道浦濱路320號浦口科創(chuàng)廣場科創(chuàng)總部大廈B座17樓
法律狀態(tài) -

摘要

摘要 本發(fā)明提供一種基于KAFKA的VPC配置下發(fā)方法，包括讀取并解析配置虛機(jī)VPC，獲取虛機(jī)VPC上線信息和待分配設(shè)備配置參數(shù)；基于KAFKA集群處理平臺獲取其指定主題下的配置信息；根據(jù)待分配設(shè)備的ID以及虛機(jī)VPC的ID，分別計算對應(yīng)的HashCode值；通過對KAFKA集群處理平臺配置信息以及HashCode值進(jìn)行取模后，計算待分配設(shè)備配置參數(shù)發(fā)送到KAFKA集群處理平臺的指定分區(qū)后，進(jìn)行異步下發(fā)；KAFKA集群處理平臺進(jìn)行異步監(jiān)聽，并記錄此次下發(fā)操作日志。利用KAFKA多分區(qū)的特性，在提高吞度量KFAKA的同時，也可以在同一個主題下，指定多個分區(qū)，進(jìn)而由多個分區(qū)指定多個消費(fèi)者進(jìn)行并行消費(fèi)，最后利用多消費(fèi)者的特性，達(dá)到提供VPC配置下發(fā)的吞吐量要求。