KafkaSourceRDDOffsetRange

KafkaSourceRDDOffsetRange is an offset range that one KafkaSourceRDDPartition partition of a KafkaSourceRDD has to read.

KafkaSourceRDDOffsetRange is created when:

KafkaSourceRDDOffsetRange takes the following when created:

Note
TopicPartition is a topic name and partition number.

results matching ""

    No results matching ""