Big Data, Spark, Event Hub, Scala, Azure.
incomingStream.writeStream.outputMode(“append”).format(“console”).option(“truncate”, false).start().awaitTermination() Truncate is set to false because we want to see the full body of messages. From the stream schema it is visible that there is a “body” column of a binary type, which we can convert