公开(公告)号：CN114064617A

公开(公告)日：2022-02-18

申请号：CN202010748721.6

申请日：2020-07-30

Applicant: 中移动信息技术有限公司 ,  中国移动通信集团有限公司

Inventor： 宁乃坚 ,  徐海勇 ,  陶涛 ,  尚晶 ,  何庆 ,  易娜

IPC: G06F16/215 ,  G06F16/23 ,  G06F9/54 ,  G06F21/62 ,  G06F21/60 ,  H04L67/10

Abstract: 本申请实施例提供了一种数据获取方法、装置、设备及计算机存储介质，该方法包括：根据租户与主题的第一对应关系实时从数据源中获取每个租户对应主题的数据；其中，第一对应关系包括每个租户对应的主题不同；将获取到的不同主题的数据存储于Kafka集群中对应主题的消息队列。本申请能够减少Kafka集群的内部数据冗余，有效提升Kafka集群资源的利用率。