发明授权
- 专利标题: 一种监测同步链路健康状态的方法及系统
-
申请号: CN202010175877.X申请日: 2020-03-13
-
公开(公告)号: CN111371900B公开(公告)日: 2022-07-12
- 发明人: 张海
- 申请人: 北京奇艺世纪科技有限公司
- 申请人地址: 北京市海淀区海淀北一街2号鸿城拓展大厦10、11层
- 专利权人: 北京奇艺世纪科技有限公司
- 当前专利权人: 北京奇艺世纪科技有限公司
- 当前专利权人地址: 北京市海淀区海淀北一街2号鸿城拓展大厦10、11层
- 代理机构: 北京华夏泰和知识产权代理有限公司
- 代理商 王卫忠; 李雪
- 主分类号: H04L67/1095
- IPC分类号: H04L67/1095 ; H04L43/0823 ; H04L41/06 ; H04L41/0677 ; H04L67/10
摘要:
一种监测同步链路健康状态的方法,应用于kafka数据同步系统,该方法包括:发送端通过kafka集群将验证数据发送至消费端,其中,kafka集群包括多个kafka分区,验证数据包括验证标识信息和验证时间;消费端接收发送端发送的验证数据,并将验证数据发送至存储端;监测模块从存储端获取验证数据,若监测模块验证时间满足预设时间规则,且验证标识信息与预设标识信息相同,则监测模块确定在验证时间下,与目标kafka分区和存储端对应的同步链路为健康状态,否则,确定同步链路为非健康状态,其中,目标kafka分区是与验证标识信息对应的kafka分区。本发明可以主动获取故障信息,确定出现故障的具体同步链路。
公开/授权文献
- CN111371900A 一种监测同步链路健康状态的方法及系统 公开/授权日:2020-07-03