ViewTube

Apache Kafka and Apache Flink are the two tools behind almost every real-time system — here's how they actually fit together.

How Flink remembers information separately for every stream key. A simple paper-style visual guide with a clear mental model.

I built a 3D simulator of a Formula 1 race at the Las Vegas Motor Speedway and processed telemetry from all 10 cars in real ...

How unbounded streams become finite groups that can be calculated. A simple paper-style visual guide with a clear mental ...

How a deliberate state snapshot supports upgrades, moves, and rescaling. A simple paper-style visual guide with a clear mental ...

How Flink snapshots distributed state without stopping the stream. A simple paper-style visual guide with a clear mental model.

Watch a complete local Flowplane run showing a governed mapping moving from creation and approval through runtime ...

How Flink measures progress when events arrive out of order. A simple paper-style visual guide with a clear mental model.

A card used in 3 cities in 2 minutes is a velocity attack — and a tumbling window will miss it. This episode builds the sliding ...

To know a transaction is unusual, the engine has to remember what usual looks like — without the database round trip we ruled ...

... processing • Windowing: tumbling, sliding, session • Stateful stream processing & exactly-once • Kafka Streams vs Apache Flink ...

Detection you can't act on is just a fast way of documenting a loss. This episode closes the loop: Redis as the hot decision store ...

One vessel goes dark. Another slows to 0.7 knots over a gas pipeline. A third stops in the middle of the sea and stays there.

사용자 클릭 이벤트 `evt-9001`이 Kafka partition 2 / offset 43에서 시작해 Flink의 Source, keyBy, Window State, Sink까지 이동하는 ...

A task manager dies holding per-card state, with events in flight. Do you miss the fraud, or freeze the card twice? This episode ...

Unlock the power of Apache Flink with our comprehensive guide on authenticating with Amazon Managed Service for Flink! In this ...

How do you express "a small test charge, then a big one, within 60 seconds" as code — without burying it in a tangle of ...

Backpressure keeps streaming pipelines alive by propagating demand limits upstream; it protects bursts but isn't a performance ...

... how to use Stream Processing (Apache Flink) to calculate rolling aggregations (e.g., "how many times has this card been used ...

Deep dive into Apache Sdap! Apache Sdap is built around a modular, extensible architecture that emphasizes data ingestion, ...