Kafka集群的數(shù)據(jù)傳送方法和裝置

基本信息

申請(qǐng)?zhí)?/td> CN201710090095.4 申請(qǐng)日 -
公開（公告）號(hào) CN106936896B 公開（公告）日 2019-06-25
申請(qǐng)公布號(hào) CN106936896B 申請(qǐng)公布日 2019-06-25
分類號(hào) H04L29/08（2006.01）I 分類 電通信技術(shù);
發(fā)明人 楊玉奇; 楊從安; 張宇平 申請(qǐng)（專利權(quán)）人 北京數(shù)字聯(lián)盟網(wǎng)絡(luò)科技有限公司
代理機(jī)構(gòu) 北京智匯東方知識(shí)產(chǎn)權(quán)代理事務(wù)所（普通合伙） 代理人 北京數(shù)字聯(lián)盟網(wǎng)絡(luò)科技有限公司
地址 100088 北京市海淀區(qū)知春路6號(hào)（錦秋國(guó)際大廈）16層B01
法律狀態(tài) -

摘要

摘要 本發(fā)明提供了一種Kafka集群的數(shù)據(jù)傳送方法和裝置。其中Kafka集群的數(shù)據(jù)傳送方法，該方法包括：調(diào)用預(yù)設(shè)的Kafka連接狀態(tài)接口，以利用Kafka連接狀態(tài)接口獲取Kafka集群的連接狀態(tài)標(biāo)識(shí)；識(shí)別連接狀態(tài)標(biāo)識(shí)對(duì)應(yīng)的Kafka集群的數(shù)據(jù)連接狀態(tài)；在數(shù)據(jù)連接狀態(tài)為Kafka集群中所有服務(wù)器均無法連接的情況下，停止向Kafka集群傳送數(shù)據(jù)。通過Kafka連接狀態(tài)接口可以判斷Kafka集群的連接狀態(tài)，可以及時(shí)發(fā)現(xiàn)Kafka集群的異常連接情況，并停止進(jìn)行數(shù)據(jù)傳輸，降低緩存中的本地消息隊(duì)列中數(shù)據(jù)丟失的風(fēng)險(xiǎn)，從而提高了Kafka集群的可靠性。