专利内容由知识产权出版社提供
专利名称：一种基于Kafka的优先队列的实现方法专利类型：发明专利发明人：洪金磊
申请号：CN202010966010.6申请日：20200915公开号：CN112181680A公开日：20210105
摘要：本发明公开了一种基于Kafka的优先队列的实现方法，属于大数据的技术领域，包括：创建多个topic,一个topic代表一个优先级,每个topic对应创建一个consumer；构建一个
PriorityConsumer 聚合多个优先级的consumer；根据业务情况设置PriorityConsumer每次拉取的消息数量，并给不同优先级的consumer设置不同的配额；consumer按照优先级从高到低以及配额依次消费对应topic内的数据。本发明通过构建一个PriorityConsumer 聚合多个优先级的consumer，优先级从高到低依次消费数据，通过配额来变相实现插队效果,最终实现了高优先级的消息被优先消费的效果。
申请人：的卢技术有限公司
地址：210046 江苏省南京市经济技术开发区恒泰路8号汇智科技园A1栋第11层
国籍：CN
代理机构：南京经纬专利商标代理有限公司
代理人：徐莹
更多信息请下载全文后查看
