KafkaSourceRDD is an
RDD of Kafka’s ConsumerRecords (with keys and values being collections of bytes, i.e.
KafkaSourceRDD is created when:
KafkaSourceRDD takes the following when created:
KafkaSourceRDDis requested for records (for given offsets) and in turn requests
CachedKafkaConsumerto poll for Kafka’s
KafkaSourceRDD initializes the internal registries and counters.