Determine Topic MetaData Spark Streaming Job

[Ashish Soni]

Hi All ,

What is the best way to tell spark streaming job for the no of partition to
to a given topic -

Should that be provided as a parameter or command line argument
or
We should connect to kafka in the driver program and query it

Map<TopicAndPartition, Long> fromOffsets = new HashMap<TopicAndPartition,
Long>();
fromOffsets.put(new TopicAndPartition(driverArgs.inputTopic, 0), 0L);

Thanks,
Ashish