日志流实时监控题目：基于Spark Streaming实现流处理 使用Spark Streaming、Kafka等实现日志流处理功能，可以捕获新应用日志的生成，采用流处理，对日志中存在的ERROR数据进行统计和告警 日志格式可以自己定义，可以参考正常log4j生成的日志格式。 题目分析如下：功能要求：实现实时error级别日志的统计，并作出相应处理框架要求：结合sparks