一种Kafka集群中的消息传输方法及装置[发明专利]

来源：华佗健康网

专利内容由知识产权出版社提供

专利名称：一种Kafka集群中的消息传输方法及装置专利类型：发明专利发明人：刘锋

申请号：CN201811319985.9申请日：20181107公开号：CN111163118A公开日：20200515

摘要：本发明实施例提供了一种Kafka集群中的消息传输方法及装置。本发明实施例在大尺寸消息的传输过程中，既能保证集群吞吐量不会大幅降低，还可以使得集群各节点负载更均衡，系统资源更加有效利用。另外，本发明实施例利用分区算法加速了大尺寸消息的还原速度，提高了处理响应时间；另外，偏移量保存在集群节点处，也保证了当订阅方系统崩溃恢复后可以无需再从最开始处重复消费消息，只需从当前消费位置开始处理消息，可以避免重复消费，同时也保证了数据一致性，也大大降低了时间成本。

申请人：株式会社日立制作所

地址：日本东京都

国籍：JP

代理机构：北京银龙知识产权代理有限公司

更多信息请下载全文后查看

因篇幅问题不能全部显示，请点此查看更多更全内容

查看全文