Re: Subscribe Multiple Topics Structured Streaming

2018-09-17 Thread Sivaprakash
t;, "utility-status, utility-critical"). > option("kafka.bootstrap.servers", "localhost:9092"). > option("startingOffsets", "earliest") > .load() > > > > > > On Mon, Sep 17, 2018 at 3:28 AM sivaprakash < > sivaprak

Subscribe Multiple Topics Structured Streaming

2018-09-17 Thread sivaprakash
Hi I have integrated Spark Streaming with Kafka in which Im listening 2 topics def main(args: Array[String]): Unit = { val schema = StructType( List( StructField("gatewayId", StringType, true), StructField("userId", StringType, true) ) ) val spark =