Derive required #cores for Spark from #partitions of Kafka input topic