SparkStreaming 整合kafka Demo

SparkStreaming 整合kafka Demo   這裏使用的是低級API，因爲高級API非常不好用，需要繁瑣的配置，也不夠自動化，卻和低級API的效果一樣，所以這裏以低級API做演示 你得有zookeeper和kafka 我這裏是3臺節點主機 架構圖 與高級API的區別,簡單並行(不需要創造多個輸入流，它會自動並行讀取kafka的數據)，高效（不會像receiver數據被copy兩次),

>>阅读原文<<