spark streaming消费指定的topic和partition并手动更新offset
直接上代码 scala版的import kafka.common.TopicAndPartitionimport kafka.message.MessageAndMetadataimport kafka.serializer.Decoderimport org.apache.spark.SparkExceptionimport org.apache.spark.rdd.RDD
