SaprkStreaming整合kafka（获取偏移量和异步提交偏移量）
package cn._51doit.spark.day13import org.apache.kafka.clients.consumer.ConsumerRecordimport org.apache.kafka.common.serialization.StringDeserializerimport org.apache.spark.SparkConfimport org.apache.spark.streaming.dstream.{DStream, InputDStream, Rec
