监控Kafka消费者的方法、装置、存储介质及设备
实质审查的生效
摘要
本申请公开了一种监控Kafka消费者的方法、装置、存储介质及设备,对于消费者组中的每个消费者,调用预先配置的消费进度采集工具,按照预设时间周期定期采集消费者在集群所包含的各个消息分区中的指标数据;对每个预设时间周期内所采集的各个消费进度累加求和,得到总消费进度;根据总消费进度确定消费者的运行状态;基于消费者在各个预设时间周期内的总消费进度、运行状态和消费者在各个消息分区的消费进度,生成消费者的消费日志并存储到数据库中;综上所述,在运行状态为非正常运行时发出告警提示,可及时通知用户进行相应处理,缩短发现问题的时间,避免因为处理问题不及时而引发重要生产事件,实现对消费者组中每个消费者的有效监控。
基本信息
专利标题 :
监控Kafka消费者的方法、装置、存储介质及设备
专利标题(英):
暂无
公开(公告)号 :
CN114493720A
申请号 :
CN202210133462.5
公开(公告)日 :
2022-05-13
申请日 :
2022-02-14
授权号 :
暂无
授权日 :
暂无
发明人 :
郭柄男常冬冬苑志云王雪
申请人 :
中国建设银行股份有限公司
申请人地址 :
北京市西城区金融大街25号
代理机构 :
北京集佳知识产权代理有限公司
代理人 :
李慧引
优先权 :
CN202210133462.5
主分类号 :
G06Q30/02
IPC分类号 :
G06Q30/02
IPC结构图谱
G
G部——物理
G06
计算;推算或计数
G06Q
专门适用于行政、商业、金融、管理、监督或预测目的的数据处理系统或方法;其他类目不包含的专门适用于行政、商业、金融、管理、监督或预测目的的处理系统或方法
G06Q30/00
商业,例如购物或电子商务
G06Q30/02
行销,例如,市场研究与分析、调查、促销、广告、买方剖析研究、客户管理或奖励;价格评估或确定
法律状态
2022-05-31 :
实质审查的生效
IPC(主分类) : G06Q 30/02
申请日 : 20220214
申请日 : 20220214
2022-05-13 :
公开
注:本法律状态信息仅供参考,即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载