New posts in spark-structured-streaming

Structured streaming schema from Kafka JSON - query error

Databricks spark.readstream format differences

Why does starting a streaming query lead to "ExitCodeException exitCode=-1073741515"?

Why Spark writes Null in DeltaLake Table

Why does format("kafka") fail with "Failed to find data source: kafka." (even with uber-jar)?

How do we cache / persist dataset in spark structured streaming 2.4.4

How to manually set and commit kafka offsets in spark structured streaming?

How can I read every 5 seconds in pyspark with kafka readStream?

How to read records in JSON format from Kafka using Structured Streaming?

Spark Strutured Streaming automatically converts timestamp to local time

Integrating Spark Structured Streaming with the Confluent Schema Registry

Does S3 Strong Consistency mean it is safe to use S3 as a checkpointing location for Spark Structured Streaming applications?