Kafka集群的數據傳送方法和裝置

基本信息

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

摘要

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