Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
-
None
Description
The newly implemented Structured Streaming KafkaSource did calculate the preferred locations for each topic partition, but didn't offer this information through RDD's getPreferredLocations method. So here propose to add this method in KafkaSourceRDD.