金融界2024年2月23日消息,据国家知识产权局公告,中国农业银行股份有限公司取得一项名为“一种用于ApacheKafka的消费信息流处理方法及系统“,授权公告号CN110990436B,申请日期为2019年12月。
专利摘要显示,本发明公开了一种用于Apache Kafka的消费信息流处理方法及系统,方法包括:计算拉取数据的处理时间,判断处理时间是否大于拉取超时时间,若是,则:拉取新的数据进行处理;若否,则:计算拉取数据线程暂停时间,在暂停时间内暂停拉取数据。本发明能够最大限度的利用Java线程池,提高程序运行效率,减少触发Apache Kafka选举机制的次数,进而提升信息系统的吞吐量。