中国移动运营分析实时监控平台之数据采集及SparkStreaming直连Kafka

数据采集阶段 经过自定义source，将产生的日志从服务器上缓存到kafka中，并记录自定义的Offset。 部分数据：web {"bussinessRst":"0000","channelCode":"0705","chargefee":"10000","clientIp":"222.214.151.245","gateway_id":"CMPAY","idType":"01","interFa

>>阅读原文<<