davidkhala-ms
New Contributor II

I see some issues from using pubsub as source. 

in the writeStream, both .foreach or .foreachBatch cannot work to be called when stream data arrives