N
cache
Y
kafka数据流
写入数据库
当前数据是否是异常状态
读取cache
异常记录表操作模块
异常记录表
当前时间 > 记录结束时间
当前时间 < 记录开始时间
单条配变运行数据
初始化该配变记录（INSERT标识）
获取异常未完成的记录（endTime = null）
当前配变记录是否在cache里有
不做处理
是否存在结束时间（抖动情况）
记录开始时间 = 当前时间
所有数据消费完成，通过cache里记录的变更情况（UPDATE、INSERT、DELETE、NONE）生成sql语句
设置结束时间，持续时间（UPDATE标识）
记录结束时间 = null记录持续时间 = null
