Converting code from Spark direct streaming to Spark Structured streaming from Kafka Converting code from legacy spark streaming to structured streaming,