Kafka收发消息一致性的监控方法、装置及电子设备

    公开(公告)号:CN117749599A

    公开(公告)日:2024-03-22

    申请号:CN202311656931.2

    申请日:2023-12-05

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

Patent Agency Ranking