专利内容由知识产权出版社提供
专利名称：一种基于Kafka的同步消息服务系统及实现方法专利类型：发明专利发明人：陈剑,刘航
申请号：CN202010227547.0申请日：20200326公开号：CN111555957A公开日：20200818
摘要：本发明公开一种基于Kafka的同步消息服务系统及实现方法，系统包括：主题管理模块，为主题分配具体的生产者代理服务节点和Cache节点，为每个主题分配唯一的密钥标识，提供主题和密钥的认证服务；消费管理模块，对消费组进行约束，为消费组分配具体的消费者代理服务节点，并为每个消费组分配唯一的密钥标识，提供消费组和接入密钥的认证服务；生产者代理模块，将分组后消息写入本地队列和Cache队列，批量将队列消息同步发送到Kafka，由核心守护线程与Kafka集群进行交互；以及，消费者代理模块，负责消费主题消息并做权限认证。此种技术方案可解决消息发送的顺序、消息消费的重复等问题，消息服务效果好。
申请人：孩子王儿童用品股份有限公司
地址：210000 江苏省南京市麒麟科技创新园智汇路300号
国籍：CN
代理机构：北京市兰台律师事务所
代理人：张峰
更多信息请下载全文后查看
