[發(fā)明專利]一種kafka客戶端鑒權(quán)的方法和裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201610377712.4
• 申請(qǐng)日: 2016-05-27
• 公開（公告）號(hào): CN107438061B
• 公開（公告）日: 2020-03-03
• 發(fā)明（設(shè)計(jì)）人: 孫榮章;馬澤國(guó);馮玉敏
• 申請(qǐng)（專利權(quán)）人: 北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類號(hào): H04L29/06
• 分類號(hào): H04L29/06
• 代理公司: 中原信達(dá)知識(shí)產(chǎn)權(quán)代理有限責(zé)任公司 11219
• 代理人: 張一軍;姜?jiǎng)?/td>

1.一種kafka客戶端鑒權(quán)的方法，其特征在于，包括：

通過(guò)鑒權(quán)鏈接接口接收客戶端提供的鑒權(quán)參數(shù)，所述鑒權(quán)參數(shù)由客戶端鏈接集群的分區(qū)參數(shù)topic和zk封裝得到；

根據(jù)所述鑒權(quán)參數(shù)查找對(duì)應(yīng)的集群的配置信息并返回給所述客戶端以使得所述客戶端訪問(wèn)所述集群。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述客戶端包括生產(chǎn)客戶端和消費(fèi)客戶端，所述生產(chǎn)客戶端生產(chǎn)數(shù)據(jù)并將所述數(shù)據(jù)寫入所述集群，所述消費(fèi)客戶端從所述集群讀取數(shù)據(jù)并消費(fèi)所述數(shù)據(jù)。

3.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，所述鑒權(quán)參數(shù)包括用戶名和密鑰，其中，

所述用戶名為系統(tǒng)域名；并且

若所述客戶端為生產(chǎn)客戶端，則所述密鑰為由身份表標(biāo)識(shí)、集群信息標(biāo)識(shí)、鑒權(quán)類型三個(gè)字段進(jìn)行編碼后封裝得到；

若所述客戶端為消費(fèi)客戶端，則所述密鑰為由身份表標(biāo)識(shí)、集群信息標(biāo)識(shí)、鑒權(quán)類型、消費(fèi)組四個(gè)字段進(jìn)行編碼后封裝得到。

4.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，

若所述客戶端為生產(chǎn)客戶端，則所述集群配置信息包括集群消息地址和集群分區(qū)標(biāo)識(shí)；

若所述客戶端為消費(fèi)客戶端，則所述集群配置信息包括集群消息地址、集群分區(qū)標(biāo)識(shí)、消費(fèi)組標(biāo)識(shí)和zookeeper中該集群的地址。

5.根據(jù)權(quán)利要求3所述的方法，其特征在于，根據(jù)所述鑒權(quán)參數(shù)查找對(duì)應(yīng)的集群配置信息包括：

確認(rèn)接收到的所述用戶名存在；

將所述密鑰反編碼為字符串，并校驗(yàn)所述字符串中各字段值是否存在；

如果所述各字段值均存在，則根據(jù)其中的集群信息標(biāo)識(shí)得到所述對(duì)應(yīng)的集群配置信息。

6.一種kafka客戶端鑒權(quán)的方法，其特征在于，包括：

通過(guò)集群的鑒權(quán)鏈接接口，將鑒權(quán)參數(shù)發(fā)送給所述集群，所述鑒權(quán)參數(shù)由客戶端鏈接集群的分區(qū)參數(shù)topic和zk封裝得到；

接收所述集群返回的集群配置信息；

根據(jù)所述集群配置信息，通過(guò)原生的客戶端訪問(wèn)所述集群。

7.一種kafka客戶端鑒權(quán)的裝置，所述裝置位于kafka集群，其特征在于，所述裝置包括：

鑒權(quán)服務(wù)模塊，用于通過(guò)鑒權(quán)鏈接接口接收客戶端提供的鑒權(quán)參數(shù)，所述鑒權(quán)參數(shù)由客戶端鏈接集群的分區(qū)參數(shù)topic和zk封裝得到；

信息獲取模塊，用于根據(jù)所述鑒權(quán)參數(shù)查找對(duì)應(yīng)的集群的配置信息并返回給所述客戶端以使得所述客戶端訪問(wèn)所述集群。

8.根據(jù)權(quán)利要求7所述的裝置，其特征在于，所述客戶端包括生產(chǎn)客戶端和消費(fèi)客戶端，所述生產(chǎn)客戶端生產(chǎn)數(shù)據(jù)并將所述數(shù)據(jù)寫入所述集群，所述消費(fèi)客戶端從所述集群讀取數(shù)據(jù)并消費(fèi)所述數(shù)據(jù)。

9.根據(jù)權(quán)利要求7或8所述的裝置，其特征在于，所述鑒權(quán)參數(shù)包括用戶名和密鑰，其中，

所述用戶名為系統(tǒng)域名；并且

若所述客戶端為生產(chǎn)客戶端，則所述密鑰為由身份表標(biāo)識(shí)、集群信息標(biāo)識(shí)、鑒權(quán)類型三個(gè)字段進(jìn)行編碼后封裝得到；

若所述客戶端為消費(fèi)客戶端，則所述密鑰為由身份表標(biāo)識(shí)、集群信息標(biāo)識(shí)、鑒權(quán)類型、消費(fèi)組四個(gè)字段進(jìn)行編碼后封裝得到。

10.根據(jù)權(quán)利要求7或8所述的裝置，其特征在于，

若所述客戶端為生產(chǎn)客戶端，則所述集群配置信息包括集群消息地址和集群分區(qū)標(biāo)識(shí)；

若所述客戶端為消費(fèi)客戶端，則所述集群配置信息包括集群消息地址、集群分區(qū)標(biāo)識(shí)、消費(fèi)組標(biāo)識(shí)和zookeeper中該集群的地址。

11.根據(jù)權(quán)利要求9所述的裝置，其特征在于，所述信息獲取模塊還用于：

確認(rèn)接收到的所述用戶名存在；

將所述密鑰反編碼為字符串，并校驗(yàn)所述字符串中各字段值是否存在；

如果所述各字段值均存在，則根據(jù)其中的集群信息標(biāo)識(shí)得到所述對(duì)應(yīng)的集群配置信息。