Streaming with PyFlink and Redpanda

Week 7 of Data Engineering Zoomcamp by @DataTalksClub complete

Just finished Module 7 - Streaming with PyFlink. Learned how to:

• Set up Redpanda as a Kafka replacement
• Build Kafka producers and consumers in Python
• Create tumbling and session windows in Flink
• Analyze real-time taxi trip data with stream processing

Here's my homework solution: https://github.com/Derrick-Ryan-Giggs/Streaming-Homework

You can sign up here: https://github.com/DataTalksClub/data-engineering-zoomcamp/