Queries with streaming sources must be executed with writeStream.start(); Pyspark; Spark Structured streaming
I have read streaming data and then I tried to apply a function on it. I want to write the return value of that function to a kafka topic. Here, I have shown a sample of my code trying to write to console.