根本:詳解receiver based Dstream

使用注意事項 1. receiver 會像正常task一樣，由driver調度到executor，並佔用一個cpu，與正常task不同，receiver是常駐線程 2. receiver個數 KafkaUtils.createStream調用次數決定，調用一次產生一個receiver 3. al topicMap = Map("page_visits" -> 1) map的value對應的數值實際

>>阅读原文<<