一种基于kafka-connect的数据传递方法

    公开(公告)号:CN112565333A

    公开(公告)日:2021-03-26

    申请号:CN202011210831.3

    申请日:2020-11-03

    IPC分类号: H04L29/08 H04L29/06 H04L12/26

    摘要: 本发明公开了一种基于kafka‑connect的数据传递方法,包括:生成与源kafka的topic对应的kafka‑connector,并通过kafka‑connector生成对应的task任务;task任务监听该源kafka的topic是否有数据变化;如果确定task任务监听该源kafka的topic有数据变化,则判断源kafka是否与目标kafka联通;如果源kafka与目标kafka联通,执行推送数据到目标kafka的逻辑,并通过kafka‑connector记录对应的推送位置。通过上述方式,本发明所公开的基于kafka‑connect的数据传递方法能够使得信息数据的推送效率高,接近于实时推送,而且会自动记录推送的位置,在断开之后重新连接,会在对应的位置重新续上,大大提升了用户的体验。

    一种网络安全评估预警系统
    5.
    发明公开

    公开(公告)号:CN115935339A

    公开(公告)日:2023-04-07

    申请号:CN202111158308.5

    申请日:2021-09-30

    摘要: 本发明公开了一种网络安全评估预警系统,包括模型训练单元、信息采集单元、安全评估单元;模型训练单元将训练样本数据作为训练集输入到风险评估模型中进行模型训练,生成训练好的风险评估模型;信息采集单元用于从网络中获取网络基本信息并发送至所述安全评估单元;安全评估单元用于调用模型训练单元中训练好的风险评估模型,导入信息采集单元发送的网络基本信息到该训练好的风险评估模型中,获取由风险评估模型输出的风险评估结果。通过本发明的系统可以实现对网络安全问题的智能化监控和预警。