一种Kafka中新增topic的消费数据自动持久化方法
基本信息
申请号 | CN202011350178.0 | 申请日 | - |
公开(公告)号 | CN112486986A | 公开(公告)日 | 2021-03-12 |
申请公布号 | CN112486986A | 申请公布日 | 2021-03-12 |
分类号 | G06F16/27(2019.01)I;G06F16/25(2019.01)I;G06F16/22(2019.01)I | 分类 | 计算;推算;计数; |
发明人 | 庞文俊;陈继;张长志;廖开枫;李小超;伊晓强 | 申请(专利权)人 | 清创网御(合肥)科技有限公司 |
代理机构 | 合肥律众知识产权代理有限公司 | 代理人 | 殷娟 |
地址 | 230000安徽省合肥市经济技术开发区习友路5999号清华大学合肥公共安全研究院4号楼507室 | ||
法律状态 | - |
摘要
摘要 | 本发明公开了一种Kafka中新增topic的消费数据自动持久化方法,在管理页面提供新增/删除topic对应的数据库存储表的功能,实现topic及其对应的数据库存储表的灵活控制;新增topic的Consumer在消费该topic中的消息时,可以自动将消费数据保存至数据库对应的存储表中。 |
