Diagram of Apache Flink coordinator and sink operators exchanging pre-commit and commit calls during a checkpoint barrier.

Inside Apache Flink's Two-Phase Commit Sink: Exactly-Once Guarantees Across Sinks

How Apache Flink coordinates checkpoints with sink writers via a two-phase commit protocol to deliver end-to-end exactly-once guarantees across Kafka, filesystems, and databases.

September 5, 2026 · 12 min · 2435 words · martinuke0
Abstract visualization of event streams merging and branching through nodes, representing a Kafka Streams topology.

Designing Kafka Streams Topologies: A Deep Dive into Real-Time Stream Processing for Production

How to design Kafka Streams topologies that survive real production workloads — covering topology shapes, state store sizing, exactly-once semantics, and the failure modes that bite at scale.

September 2, 2026 · 11 min · 2284 words · martinuke0
Diagram of a Kafka Streams topology with state stores and processors.

Architecting Kafka Streams Topologies: A Deep Dive into Real-Time Stream Processing Logic and State Management

A practical guide to building, scaling, and debugging Kafka Streams topologies, focusing on state stores, windowing, and production‑ready architecture.

May 28, 2026 · 8 min · 1683 words · martinuke0
Diagram of a Kafka Streams topology with multiple processors.

Architecting Kafka Streams Real-Time Stream Processing Topologies: From Low-Level DSL to Production-Ready Pipelines

A deep dive into building Kafka Streams topologies, from the DSL basics to production‑ready patterns, with concrete architecture diagrams and scaling strategies.

May 23, 2026 · 8 min · 1526 words · martinuke0
Illustration of a data stream with timestamps and a watermark line.

Where Stream Processing Systems Draw the Line for Late Data

A deep dive into how stream engines decide what counts as late data, the mechanisms they expose, and best‑practice patterns for robust pipelines.

May 18, 2026 · 7 min · 1471 words · martinuke0
Feedback