We're starting module 7 on stream processing.
Reminder: the previous homework deadline is in less than 24 hours.
The materials were created by Zach Wilson, who ran a Flink stream for the course last year. Alexey recorded an updated Apache Flink workshop to reflect support for Flink 2.x and modern Python versions (3.12, 3.9, 3.8).
It covers:
• Streaming fundamentals in Data Engineering Zoomcamp
• Kafka/Redpanda, Python producers and consumers
• Writing streaming events to PostgreSQL
• Apache Flink setup with Docker
• Flink jobs for stream processing
• Windowing, watermarks, and late events
• Real-time aggregations with Flink
Homework deadline: 17 March, 12 AM CET
Learn here: https://github.com/DataTalksClub/data-engineering-zoomcamp/tree/main/07-streaming
Post #210
13K