Big Data, Spark, Event Hub, Scala, Azure.
incomingStream.writeStream.outputMode("append").format("console").option("truncate", false).start().awaitTermination() Output: root |-- body: binary (nullable = true) |-- offset: long (nullable = true) |-- seqNumber: long (nullable = true) |-- enqueuedTime: long (nullable = true) |-- publisher: