SparkStreaming+kafka的Direct模式的整合

SparkStreaming+Kafka receiver模式 receiver模式原理圖   receiver模式理解: 在SparkStreaming程序運行起來後,Executor中會有receiver tasks接收kafka推送過來的數據。數據會被持久化,默認級別爲MEMORY_AND_DISK_SER_2,這個級別也可以修改。receiver task對接收過來的數據進行存儲和備份,這
相關文章
相關標籤/搜索