~/talk

A Data Streaming Architecture with Apache Flink #bbuzz

Talkat Berlin Buzzwords 2016 · 2016-06-05..06-07· [data-engineering]
slides:none on file

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

  1. 0:00Introduction to Flink
  2. 2:57Why streaming is transformative
  3. 11:43Flink features overview
  4. 12:06Transforming batch ETL to streaming
  5. 20:14Streaming ETL demo setup
  6. 23:29Running the streaming ETL job
  7. 31:26Closing and resources
~/search
type to search 6,249 conferences, 138,987 speakers and 185,172 talks
~/help
cmdctrl k
search every conference, speaker and series
/
focus the filter search
h
home
c
conferences
s
speakers
e
series
t
light / dark — the status bar button does the same
?
this help
esc
close this, then clear every filter — or just the search, while you are typing in it

Ignored while you are typing. Pages without a filter rail have no search to focus.