首页> 中国专利> 一种Kafka中新增topic的消费数据自动持久化方法

一种Kafka中新增topic的消费数据自动持久化方法

页面导航

摘要
著录项
法律信息
相似文献

摘要

本发明公开了一种Kafka中新增topic的消费数据自动持久化方法，在管理页面提供新增/删除topic对应的数据库存储表的功能，实现topic及其对应的数据库存储表的灵活控制；新增topic的Consumer在消费该topic中的消息时，可以自动将消费数据保存至数据库对应的存储表中。

著录项

公开/公告号CN112486986A

专利类型发明专利
公开/公告日2021-03-12

原文格式PDF
申请/专利权人清创网御(合肥)科技有限公司;
展开▼

申请/专利号CN202011350178.0
发明设计人庞文俊;陈继;张长志;廖开枫;李小超;伊晓强;
展开▼

申请日2020-11-26
分类号G06F16/22(20190101);G06F16/25(20190101);G06F16/27(20190101);
代理机构34147 合肥律众知识产权代理有限公司;
代理人殷娟
地址 230000 安徽省合肥市经济技术开发区习友路5999号清华大学合肥公共安全研究院4号楼507室
入库时间 2023-06-19 10:11:51

法律信息

法律状态公告日

法律状态信息

法律状态
2023-07-18

发明专利申请公布后的驳回 IPC(主分类):G06F16/22 专利申请号:2020113501780 申请公布日:20210312

发明专利申请公布后的驳回

相似文献

专利
中文文献
外文文献

1. 一种Kafka中新增topic的消费数据自动持久化方法 [P] . 中国专利： CN112486986A . 2021-03-12
2. 一种Kafka数据消费积压情况监控报警方法 [P] . 中国专利： CN111290908A . 2020-06-16
3. Meter e.g. water meter, reading retrieving method for consumer, involves testing identity of consumer in mobile retrieval unit, and measuring, buffering, processing and transmitting data in received response to host system [P] . 德国专利： DE102006050729A1 . 2008-05-21

机译：仪表例如水表，一种用于消费者的读取检索方法，涉及在移动检索单元中测试消费者的身份，并在接收到的响应中测量，缓冲，处理和传输数据到主机系统
4. A method of providing interuptible load in a market for services to an electricity network including providing load control terminals at consumer locations in the network, determining a target for consumer loads, recieving data from the load control terminals, selecting one or more of the currently active consumer loads, and sending an arm signal to the terminals for the selected loads. [P] . NZ584058A . 2013-01-25

机译：一种在市场中为电力网络提供可互换负载以提供服务的方法，包括在网络中的用户位置提供负载控制终端，确定用户负载目标，从负载控制终端接收数据，选择一个或多个当前活动的负载消费负载，并向选定的负载向终端发送布防信号。
5. METHOD OF AND SYSTEM FOR FINDING CONSUMER PRODUCT RELATED INFORMATION ON THE INTERNET USING AUTOMATIC REGISTRATION SOLICITATION TECHNIQUES TO HELP CREATE UPN/TM/PD/URL DATA LINKS STORED IN AN INTERNET-BASED RELATIONAL DATABASE SERVER [P] . 美国专利： US6631357B1 . 2003-10-07

机译：利用自动注册请求技术在互联网上查找消费者产品相关信息的方法和系统，以帮助创建存储在基于互联网的关系数据库服务器中的UPN / TM / PD / URL数据链接