一种监测同步链路健康状态的方法及系统
摘要:
一种监测同步链路健康状态的方法,应用于kafka数据同步系统,该方法包括:发送端通过kafka集群将验证数据发送至消费端,其中,kafka集群包括多个kafka分区,验证数据包括验证标识信息和验证时间;消费端接收发送端发送的验证数据,并将验证数据发送至存储端;监测模块从存储端获取验证数据,若监测模块验证时间满足预设时间规则,且验证标识信息与预设标识信息相同,则监测模块确定在验证时间下,与目标kafka分区和存储端对应的同步链路为健康状态,否则,确定同步链路为非健康状态,其中,目标kafka分区是与验证标识信息对应的kafka分区。本发明可以主动获取故障信息,确定出现故障的具体同步链路。
公开/授权文献
0/0