在有海量消息数据上报和处理的物联网设施管理系统中添加Kafka消息中间件能够异步地传输消息,增加了微服务系统的灵活性和可扩展性,但其带来的影响比如延时和资源消耗也是实际运用中需要考虑的。论文提出了一种基于优化KafkaProducer中Serializer接口的内存分配的改进方案,降低了添加Kafka消息中间件造成的额外资源消耗,为Kafka的应用打下了基础。Adding Kafka message middleware to the IoT facility management system with massive message data reporting and processing can transmit messages asynchronously,which increases the flexibility and scalability of the microservice system,but its effects such as delay and resource consumption are also need to be considered.This paper proposes an improved scheme based on optimizing the memory allocation of the Serializer interface in KafkaProducer,which reduces the additional resource consumption caused by Kafka and lays the foundation for the application of Kafka message middleware.
机构地区武汉邮电科学研究院 烽火通信科技股份有限公司
出处《计算机与数字工程》 2021年第3期546-549,共4页Computer & Digital Engineering
关键词Kafka 异步 内存分配 优化Kafka asynchronous memory allocation optimization
分类号TP393.4 [自动化与计算机技术—计算机应用技术]