(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210979920.7 (22)申请日 2022.08.16 (71)申请人 深圳市酷 开网络科技股份有限公司 地址 518052 广东省深圳市南 山区粤海街 道高新区社区高新南四道18号创维半 导体设计大厦东 座2306 (72)发明人 余辉　 (74)专利代理 机构 深圳市君胜知识产权代理事 务所(普通 合伙) 44268 专利代理师 陈专 (51)Int.Cl. G06F 16/25(2019.01) G06F 16/28(2019.01) (54)发明名称 基于kafka的人群订阅的方法、 系统、 终端及 存储介质 (57)摘要 本发明公开了一种基于kafka的人群订阅方 法、 系统、 终端及存储介质， 所述方法包括： 获取 不同人群的人群数据， 控制人群生产程序将所述 人群数据发送至kafka， 并接收所述kafka返回的 状态数据， 将所述状态数据存储至关系型数据库 管理系统中； 当接收订阅页面发送的请求时， 将 所述状态数据在所述订阅页面进行展示， 并在所 述订阅页面中订阅人群； 基于所述人群， 获取所 述关系型数据库管理系统中所述人群对应的目 标状态数据， 并将所述目标状态数据发送至所述 kafka中进行消费， 以完成所述人群的订阅。 本发 明通过各个团队在使用用户画 像系统时， 采取订 阅的方式， 就能够获取所需要的人群进行数据抽 取， 并且订阅可以在人群执行之前或人群执行完 成之后。 权利要求书2页 说明书7页 附图4页 CN 115408458 A 2022.11.29 CN 115408458 A 1.一种基于kafka的人群订阅方法， 其特 征在于， 所述基于kafka的人群订阅方法包括： 获取不同人群的人群数据， 控制人群生产程序将所述人群数据发送至kafka， 并接收所 述kafka返回的状态数据， 将所述状态数据存 储至关系型 数据库管理系统中； 当接收订阅页面发送的请求时， 将所述状态数据在所述订阅页面进行展示， 并在所述 订阅页面中订阅人群； 基于所述人群， 获取所述关系型数据库管理系统中所述人群对应的目标状态数据， 并 将所述目标状态数据发送至所述 kafka中进行消费， 以完成所述人群的订阅。 2.根据权利要求1所述的基于kafka的人群订阅方法， 其特征在于， 所述获取不同人群 的人群数据， 控制人群生产程序将所述人群数据 发送至kafka， 并接收所述kafka返回的状 态数据， 将所述状态数据存 储至关系型 数据库管理系统中， 具体包括： 获取不同人群的人群数据， 控制人群生产程序将所述人群数据按照 生产的规范和数据 的规范发送至kafka 中； 当所述kafka将接收的所述人群数据进行存储时， 接收所述k afka返回不同人群的状态 数据， 并将所述状态数据标记后存 储至关系型 数据库管理系统中。 3.根据权利要求2所述的基于kafka的人群订阅方法， 其特征在于， 所述状态数据包括 Topic、 par tition、 开始偏移量和结束偏移量。 4.根据权利要求1所述的基于kafka的人群订阅方法， 其特征在于， 所述当接收订阅页 面发送的请求时， 将所述状态数据在所述订阅页面进行展示， 并在所述订阅页面中订阅人 群， 具体包括： 当订阅页面在预设时间内发送查看状态数据的请求 时， 控制所述关系型数据库管理系 统将所有人群的状态数据在所述 订阅页面进行展示； 基于所述状态数据， 在所述 订阅页面选择 人群进行订阅。 5.根据权利 要求4所述的基于kafka的人群订阅方法， 其特征在于， 所述基于所述人群， 获取所述关系型数据库管理系统中所述人群对应的目标状态数据， 并将所述目标状态数据 发送至所述 kafka中进行消费， 以完成所述人群的订阅， 具体包括： 基于订阅的所述人群， 根据 所述人群的标识从所述关系型数据库管理系统中获取所述 人群对应的目标状态数据； 基于所述目标状态数据启动人群消费程序， 控制所述人群消费程序向所述kafka发送 获取所述人群的人群数据请求； 当所述人群消费程序接收所述人群数据时， 控制所述人群消费程序将人群订 阅成功的 状态发送至所述 订阅页面。 6.根据权利要求1所述的基于kafka的人群订阅方法， 其特征在于， 所述人群数据包括 明细数据和结束符号。 7.根据权利要求4所述的基于kafka的人群订阅方法， 其特征在于， 所述预设时间为5 ‑ 20s。 8.一种基于kafka的人群订阅系统， 其特 征在于， 所述基于kafka的人群订阅系统包括： 订阅模块， 用于订阅人群、 查看人群的执 行状态和人群在Kafka 中的状态数据； 生产人群模块， 用于按照生产的规范以及数据的规范将人群数据发送至Kafka和返回 人群的状态数据；权　利　要　求　书 1/2 页 2 CN 115408458 A 2kafka模块， 用于分区存 储人群数据； 消费人群模块， 用于获取订阅的人群中的状态数据， 并将所述状态数据进行人群的数 据消费。 9.一种终端， 其特征在于， 所述终端包括： 存储器、 处理器及存储在所述存储器上并可 在所述处理器上运行的基于kafka的人群订阅程序， 所述基于kafka的人群订阅程序被所述 处理器执行时实现如权利要求1 ‑7任一项所述的基于kafka的人群订阅方法的步骤。 10.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储有基于 kafka的人群订阅程序， 所述基于kafka的人群订阅程序被处理器执行时实现如权利要求 1‑ 7任一项所述的基于kafka的人群订阅方法的步骤。权　利　要　求　书 2/2 页 3 CN 115408458 A 3