[Live Demo] Spark Streaming With Kafka | Read, Parse And Transform Kafka Json In Spark

[@beRandom825]

Hi, thanks for the detailed explanation, was looking for this implementation in Java. I have a question what if i have to have a schema in a different class(with getters and setters) instead of creating a StructType(). Can you please help

[@derhotcenplotz3464]

Awesome!

[@nabil.ansari]

thank you so much. I was searching for this for so long and this is the only proper java implementation of parsing json in spark. Everything is working fine but for some reason all the column values are returning as null. Can you help me with that??

[@agnitaa1]

Hi, can you please also share how to write the junit test cases for the above code. Thank you!