I wrote a simple streaming data pipeline project post, using Apache Kafka, Apache Flink and PostgreSQL DB. Hope this helps someone. lmk if any questions/thoughts/concerns, etc