-
公开(公告)号:CN117749599A
公开(公告)日:2024-03-22
申请号:CN202311656931.2
申请日:2023-12-05
Applicant: 北京神州泰岳软件股份有限公司
IPC: H04L41/0631 , H04L43/0823 , H04L43/0805
Abstract: 本发明提供的Kafka收发消息一致性的监控方法、装置及电子设备,获取预先生成的监控规则,基于监控规则获取Kafka主题名称信息对应的Kafka分区和Kafka分区的消息偏移量;基于Kafka分区的消息偏移量以及监控策略信息对应的预设阈值判断Kafka分区的消息收发是否出现异常;如果出现异常,根据预设的通知类型生成异常信息并按通知类型发送至客户端。该方式中通过灵活自定义的监控规则,可以获取主题名称信息对应的分区和分区的消息偏移量,然后根据消息偏移量及其对应的预设阈值,能自动及时发现故障异常,并将该故障异常通过多种方式主动通知给用户,从而提升监控人员工作效率和运维人员故障处理能力。