org.apache.spark.streaming.kafka
Represents any object that has a collection of OffsetRanges. This can be used to access the offset ranges in RDDs generated by the direct Kafka DStream (see KafkaUtils.createDirectStream()).
KafkaUtils.createDirectStream()
KafkaUtils.createDirectStream(...).foreachRDD { rdd => val offsetRanges = rdd.asInstanceOf[HasOffsetRanges].offsetRanges ... }
Represents any object that has a collection of OffsetRanges. This can be used to access the offset ranges in RDDs generated by the direct Kafka DStream (see
KafkaUtils.createDirectStream()
).