SpringBootKafka Strom 实时风控统计 处理流程 1.实时解析日志报文,并把解析后的日志推送到kafka当中 2.storm从kafka中读取数据,并根据实时统计和计算 规则: 1.消费金额(一天内的消费金额不能>2W)如果累计消费大于额度,进行短信或者电话确认 2.登录地点异常预警(如上次根据IP得到的登录地点为北京,这次登录的地点为上海)此种情况应该给予推送或者重新发短信确认