Streaming pipeline repo for data engineering training program - View it on GitHub