一种基于Kafka分布式消息处理方法及数据总线系统
实质审查的生效
摘要
本发明公开了一种基于Kafka分布式消息数据总线系统，其特征在于，包括：数据模型仓库，用于管理Kafka消息主题的数据模型；消息同步模块，用于Kafka消息的落地；监控模块，用于采集各组件监控数据以及异常告警；所述的数据模型仓库存储Kafka消息主题的数据模型的版本历史，同时提供多种兼容性设置，所述的消息同步模块中设有数据库同步器，对象存储同步器、Elasticsearch同步器和API工具，所述API工具用于同步任务管理操作和提供监控数据，消息同步模块根据同步任务配置启动对应的同步器将Kafka消息落地到数据库、对象存储或者Elasticsearch中供所需系统使用，通过任务配置就能实现消息数据的分发存储，节省了不同数据分发的开发成本。
基本信息
专利标题 ：
一种基于Kafka分布式消息处理方法及数据总线系统
专利标题（英）：
暂无
公开（公告）号 ：
CN114553970A
申请号 ：
CN202210116405.6
公开（公告）日 ：
2022-05-27
申请日 ：
2022-02-07
授权号 ：
暂无
授权日 ：
暂无
发明人 ：
缪士宣
申请人 ：
上海数依数据科技有限公司
申请人地址 ：
上海市杨浦区武东路198号603-7室
代理机构 ：
苏州尚为知识产权代理事务所(普通合伙)
代理人 ：
陈钢
优先权 ：
CN202210116405.6
主分类号 ：
H04L69/06
IPC分类号 ：
H04L69/06 H04L69/00 H04L67/1095 H04L41/0631 G06F16/28 G06F16/21
法律状态
2022-06-14 ：
实质审查的生效
IPC(主分类) : H04L 69/06
申请日 : 20220207
申请日 : 20220207
2022-05-27 ：
公开
注：本法律状态信息仅供参考，即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载
