根本:详解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对应的数值实际

>>阅读原文<<