买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网恭喜中国建设银行股份有限公司申请的专利Kafka的查询方法、装置、存储介质及设备获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN115174423B 。

龙图腾网通过国家知识产权局官网在2025-03-07发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202210814063.5，技术领域涉及：H04L41/50；该发明授权Kafka的查询方法、装置、存储介质及设备是由包坤;赵少山设计研发完成，并于2022-07-12向国家知识产权局提交的专利申请。

本Kafka的查询方法、装置、存储介质及设备在说明书摘要公布了：本申请公开了一种Kafka的查询方法、装置、存储介质及设备，对查询请求进行解析得到各个信息项；当标签数据库中包含前端本地预存的身份标签时，从预设的集群地址数据库中获取集群地址；访问集群地址所属的集群，得到集群的多个topic名称、与每个topic名称对应的用户名单；与用户预先输入的topic名称对应的用户名单中包含身份标签所示的用户名，读取集群中的目标topic数据得到作业流；依据处理顺序依次向前端发送各个消息，与现有技术相比，发送给前端的各个消息均来自目标topic数据，而不是集群中的全部topic数据，避免了集群下除目标topic数据之外的其他topic数据的泄露。

本发明授权Kafka的查询方法、装置、存储介质及设备在权利要求书中公布了：1.一种Kafka的查询方法，其特征在于，包括：在接收到前端发送的查询请求时，对查询请求进行解析，得到各个信息项；所述各个信息项至少包括前端本地预存的身份标签，以及用户预先输入的项目ID、topic名称、数据源名称、操作环境；所述前端本地预存的身份标签为cookie信息或令牌信息；判断标签数据库中是否包含所述前端本地预存的身份标签，包括：若所述前端本地预存的身份标签为所述cookie信息，则认证系统中的拦截器调用auth-client中的SDK，将所述cookie信息传入所述认证系统中进行认证；若所述前端本地预存的身份标签为所述令牌信息，则Kafka-query服务申请AK和SK，将所述AK和所述SK发送至auth-server，得到所述auth-server返回的目标令牌信息，将所述目标令牌信息和所述AK发送至数据管理接口，以使所述数据管理接口比较所述目标令牌信息和所述令牌信息是否一致；当标签数据库中包含所述前端本地预存的所述身份标签时，从预设的集群地址数据库中，获取与所述项目ID对应、且与所述topic名称对应、且与所述数据源名称对应、且与所述操作环境对应的集群地址；访问所述集群地址所属的集群，得到所述集群的多个topic名称、与每个所述topic名称对应的用户名单；当与所述用户预先输入的所述topic名称对应的用户名单中，包含所述身份标签所示的用户名时，读取所述集群中的目标topic数据，得到作业流；所述目标topic数据包括所述topic名称与用户预先输入的所述topic名称相同的topic数据；所述作业流包括多个消息，以及各个所述消息的处理顺序；依据各个所述消息的处理顺序，依次向所述前端发送各个所述消息；在向所述前端发送各个所述消息的过程中，统计所述作业流中还未被发送的消息的数量，得到所述目标topic数据的消费堆积量；对于所述作业流中的每个所述消息，从所述集群中获取所述消息的属性信息；其中，所述属性信息包括但不限于为：组标识、所处分区、发布时间、数据源；将所述消费堆积量，以及各个所述消息的所述属性信息发送给所述前端，以使所述前端通过预设界面向所述用户展示所述消费堆积量，以及各个所述消息的所述属性信息。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人中国建设银行股份有限公司，其通讯地址为：100033 北京市西城区金融大街25号；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。