Flink
9 items using Flink
Projects
Clickstreamer — Real-time Clickstream Pipeline
End-to-end clickstream analytics pipeline using Kafka, Apache Flink, ClickHouse, and Grafana with a full Docker Compose setup.
Real-time Ingestion Pipeline
FeaturedA high-throughput streaming ingestion platform built with Apache Flink and Kafka, processing 500k+ events/sec into ClickHouse.
Blog Posts
Flink Series, Part 5: Performance & Production
Making Flink production-ready — diagnosing backpressure, tuning parallelism, sizing network buffers, and monitoring with metrics.
Flink Series, Part 4: Exactly-Once & Checkpointing
How Flink guarantees end-to-end correctness after failures — Chandy-Lamport barriers, two-phase commit, checkpoints vs savepoints.
Flink Series, Part 3: State Management
How Flink stores and manages state — keyed vs operator state, state backends, TTL, and practical stateful patterns.
Flink Series, Part 2: Time & Windows
Flink's most powerful feature — temporal reasoning over streams. Event time, watermarks, and window types explained.
Flink Series, Part 1: DataStream API
The fundamental building block of Flink — how to read, transform, and write streams using the DataStream API.
Flink Series, Part 0: Overview
What is Apache Flink, what problem does it solve, and how does it differ from Spark Streaming? A roadmap for the series.
How Flink's Exactly-Once Semantics Actually Work
A deep dive into Flink's checkpointing mechanism and how it guarantees exactly-once processing even when jobs fail and restart.