神州泰岳申请Kafka收发消息一致性的监控方法、装置及电子设备专利

　　金融界2024年3月22日消息，据国家知识产权局公告，北京神州泰岳软件股份有限公司申请一项名为“Kafka收发消息一致性的监控方法、装置及电子设备“，公开号CN117749599A，申请日期为2023年12月。

　　专利摘要显示，本发明提供的Kafka收发消息一致性的监控方法、装置及电子设备，获取预先生成的监控规则，基于监控规则获取Kafka主题名称信息对应的Kafka分区和Kafka分区的消息偏移量；基于Kafka分区的消息偏移量以及监控策略信息对应的预设阈值判断Kafka分区的消息收发是否出现异常；如果出现异常，根据预设的通知类型生成异常信息并按通知类型发送至客户端。该方式中通过灵活自定义的监控规则，可以获取主题名称信息对应的分区和分区的消息偏移量，然后根据消息偏移量及其对应的预设阈值，能自动及时发现故障异常，并将该故障异常通过多种方式主动通知给用户，从而提升监控人员工作效率和运维人员故障处理能力。