公开(公告)号：CN110647547A

公开(公告)日：2020-01-03

申请号：CN201910895091.2

申请日：2019-09-20

Applicant: 北京百分点信息科技有限公司

Inventor： 黄伟 ,  廖锐 ,  刘译璟 ,  于帮付 ,  马志峰 ,  杜晓梦 ,  苏海波 ,  苏萌 ,  左云鹏 ,  陆攀

IPC: G06F16/2455 ,  G06F16/2458

Abstract: 本说明书实施例公开了一种消费延迟监控方法、装置、电子设备及计算机可读存储介质。其中，该方法应用于基于Spark Streaming框架的流处理系统，包括：按照预设时间间隔从Kafka系统中读取流数据，所述流数据中包括多条携带有生产时间戳的业务数据；基于所述流数据中的目标业务数据的生产时间戳确定所述Kafka系统的消费延迟时间，其中，所述目标业务数据为所述流数据中生产时间戳最晚的业务数据；基于所述消费延迟时间，对所述Kafka系统进行消费延迟监控。本申请能够实现对Kafka系统中的消费延迟信息的有效监控。