A Data Streaming Architecture with Apache Flink #bbuzz
summary
Shows converting a batch ETL pipeline into a streaming ETL built with Apache Flink reading from Apache Kafka and writing to Elasticsearch, Cassandra and a per-minute rolling file sink. Demonstrates processing 500 MB of historical tweets with event-time watermarks, 10s tumbling windows for language counts and a one‑minute sliding window for top‑N word frequencies, using Flink state backends, checkpoints and an exactly-once Kafka connector so windows and replays produce correct results despite out‑of‑order and late arrivals.
AI-written summary · about
chapters (7)
- 0:00Introduction to Flink
- 2:57Why streaming is transformative
- 11:43Flink features overview
- 12:06Transforming batch ETL to streaming
- 20:14Streaming ETL demo setup
- 23:29Running the streaming ETL job
- 31:26Closing and resources
related talks
38mApache Flink: A Very Quick Guide
42mApache Flink deep-dive #bbuzz
49mscale.bythebay.io: Stephan Ewen, Apache Flink and the Next Wave of Stream Processing Applications
41mBeyond the Hype: When Apache Flink Solves Real Problems
30mBuild and run streaming applications with Apache Flink and Amazon Kinesis Data Analytics
50mStream Processing Smackdown: Kafka Streams vs. Apache Flink
40mFrom concept to production; the fastest way to develop & deploy Apache Flink jobs
34mBeaming Flink to the Cloud @ Netflix
