Data Streaming Pipeline (Kafka, Flink and Postgres)