Streaming spark job to consume events and write them into parquet