公开(公告)号：CN115794822A

公开(公告)日：2023-03-14

申请号：CN202211505418.9

申请日：2022-11-28

Applicant: 深圳前海微众银行股份有限公司

Inventor： 姬岑晨 ,  李勇 ,  黄叶飞 ,  卢道和 ,  罗锶 ,  边元乔 ,  常亮 ,  胡思文 ,  郑喜生

IPC: G06F16/22 ,  G06F16/27 ,  G06F16/28 ,  G06F16/23

Abstract: 本发明实施例涉及一种数据存储方法及装置。该方法包括：在第i+1步长的步长起始时间，将第i步长的有效分区中的数据存储至第i+1步长的有效分区中；在第i+1步长从步长起始时间至步长结束时间增加的各数据操作中，按照各数据操作的产生时间的先后顺序选择任一数据操作，若数据操作为添加数据，则将数据操作对应的添加数据存储至第i+1步长的有效分区；若数据操作为删除数据，则在第i+1步长的有效分区查找到该数据操作对应的有效数据，将有效数据移动至数据操作的产生时间对应的失效分区中，并将有效数据的失效时间修改为失效分区对应的失效时间。按照上述方式存储数据的话，在查询数据时可以减少访问的分区数，提高查询速度。

公开(公告)号：CN113703982A

公开(公告)日：2021-11-26

申请号：CN202111017211.2

申请日：2021-08-31

Applicant: 深圳前海微众银行股份有限公司

Inventor： 李勇 ,  卢道和 ,  罗锶 ,  黄叶飞 ,  边元乔 ,  陈晓峰 ,  常亮 ,  姬岑晨 ,  胡思文 ,  郑喜生

IPC: G06F9/50

Abstract: 本发明涉及金融科技技术领域，公开了一种使用KAFKA的数据消费方法、装置、终端设备以及计算机存储介质。该使用KAFKA的数据消费方法通过KAFKA消费端按照实例注册规则注册数据消费实例，其中，所述实例注册规则包括：单个KAFKA主题的单个partition对应一个数据消费实例的一个消费线程；根据所述数据消费实例的权重和所述数据消费实例对应的KAFKA主题的partition进行负载均衡操作；保持负载均衡状态供所述数据消费实例进行数据消费。本发明实现了使用KAFKA的轻量级、高可用的数据消费方案。