SparkStreaming與Kafka整合遇到的問題及解決方案

最近工作中是做日誌分析的平臺,採用了sparkstreaming+kafka,採用kafka主要是看中了它對大數據量處理的高性能,處理日誌類應用再好不過了,採用了sparkstreaming的流處理框架 主要是考慮到它本身是基於spark核心的,以後的批處理可以一站式服務,並且可以提供準實時服務到elasticsearch中,可以實現準實時定位系統日誌。 作者:佚名 來源:| 2017-08-03
相關文章
相關標籤/搜索