基于Flink和Kafka实时监控销售数据的方法、系统及装置

摘要

本发明是有关于一种基于Flink和Kafka实时监控销售数据的方法、系统及装置。所述方法包括：由Kafka消息队列获取由用户消费而产生的实时销售数据；采用Flink分布式运算系统，对所述实时销售数据进行统计，得到用户消费的实时交易额。本发明基于Flink和Kafka实时监控销售数据的方法、系统及装置提高了对销售数据进行分析处理的实时性。