Sandeep11
New Contributor II

Thank you all for the responses. We could get into a solution by adding readChangeFeed flag as true as additional option to the spark.readStream however kept the pipeline configs same.