SparkStream之與Kafka整合

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