一种Kafka消息发布方法、装置及存储介质
授权
摘要
本公开提供了一种Kafka消息发布方法、装置及存储介质，用于解决不符合规范的数据进入Kafka集群技术问题。本公开技术方案对Kafka的主题配置参数进行扩展，对于存在规范性检测需求的主题消息提供校验规则；替换原有逐条消息构造方法为消息工厂构造方式，根据传入的集群及主题配置参数，在消息创建按照消息校验规范生成消息，保证消息规范性和准确性；通过Kafka集群消息拦截器过滤掉不符合规范的消息，从而保证写入主题的消息都是符合规范的消息。本公开技术方案主要从服务端检测和控制写入主题的消息的规范性，能够高效地实现防止不符合规范的消息发布到Kafka集群中的风险。
基本信息
专利标题 ：
一种Kafka消息发布方法、装置及存储介质
专利标题（英）：
暂无
公开（公告）号 ：
CN113315750A
申请号 ：
CN202110403396.4
公开（公告）日 ：
2021-08-27
申请日 ：
2021-04-15
授权号 ：
CN113315750B
授权日 ：
2022-05-27
发明人 ：
王逞
申请人 ：
新华三大数据技术有限公司
申请人地址 ：
河南省郑州市郑州高新技术产业开发区杜英街166号总部大观B18楼
代理机构 ：
代理人 ：
优先权 ：
CN202110403396.4
主分类号 ：
H04L29/06
IPC分类号 ：
H04L29/06 H04L29/08
法律状态
2022-05-27 ：
授权
2021-10-19 ：
实质审查的生效
IPC(主分类) : H04L 29/06
申请日 : 20210415
申请日 : 20210415
2021-08-27 ：
公开
注：本法律状态信息仅供参考，即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载
