中國移動運營分析實時監控平臺之數據採集及SparkStreaming直連Kafka

數據採集階段 通過自定義source，將產生的日誌從服務器上緩存到kafka中，並記錄自定義的Offset。 部分數據： {"bussinessRst":"0000","channelCode":"0705","chargefee":"10000","clientIp":"222.214.151.245","gateway_id":"CMPAY","idType":"01","interFacRs

>>阅读原文<<