源码分析的spark版本是1.6。
首先，先看一下 org.apache.spark.streaming.dstream.InputDStream 的 类说明：首先，先看一下 org.apache.spark.str
阅读背景：
spark streaming 接收kafka消息之一 -- 两种接收方式
来源：互联网
分享到：
