datapipe build using spark structured streaming and kafka and persisting data into PostgreSQL database