指定offset消费--基于Spark Streaming+sp
2019-09-30 本文已影响0人
机灵鬼鬼
第一步：解析把从kafka中获取的数据，转化成DStream
第二步：把DStream调用foreachRDD方法转化成RDD
第三步：使用Spark Sql操作RDD
第一步：解析把从kafka中获取的数据，转化成DStream
第二步：把DStream调用foreachRDD方法转化成RDD
第三步：使用Spark Sql操作RDD
