import org.apache.kafka.common.serialization.StringDeserializer import org.apache.spark.SparkConf import org.apache....
itfan123