Re: Spark 2.0.2, Structured Streaming with kafka source... Unable to parse the value to Object..

You could also do this with Datasets, which will probably be a little more efficient (since you are telling us you only care about one column) ds1.select($"value".as[Array[Byte]]).map(Student.parseFrom) On Thu, Nov 17, 2016 at 1:05 PM, shyla deshpande wrote: > Hello

Re: Spark 2.0.2, Structured Streaming with kafka source... Unable to parse the value to Object..

Hello everyone, The following code works ... def main(args : Array[String]) { val spark = SparkSession.builder. master("local") .appName("spark session example") .getOrCreate() import spark.implicits._ val ds1 = spark.readStream.format("kafka").

Spark 2.0.2, Structured Streaming with kafka source... Unable to parse the value to Object..

val spark = SparkSession.builder. master("local") .appName("spark session example") .getOrCreate() import spark.implicits._ val dframe1 = spark.readStream.format("kafka"). option("kafka.bootstrap.servers","localhost:9092"). option("subscribe","student").load() *How do I deserialize