1. Stateful Stream Processing advanced

    A stream processor maintains per-vehicle state across events. What does that require operationally, and where does it break?

    2 min answer porterstatecheckpointingrebalancing
  2. Stream Processing Frameworks advanced

    A Flink job checkpoints every 60 seconds. State has grown so that one checkpoint now takes 90 seconds to complete. No configuration changes. What happens over the next hour, and which metric will not show it?

    3 min answer flinkcheckpointingbackpressurestate
  3. Stream Processing Frameworks advanced

    What justifies a stream processing framework over a simple consumer loop?

    2 min answer streamingstatewatermarkscheckpointing
  4. Stream Processing Frameworks advanced

    What should drive the choice of stream processing framework for a high-volume recommendation platform?

    2 min answer frameworksstateexactly-onceoperability
  5. Stream-Table Duality advanced

    What does stream-table duality mean practically, and how does it change system design?

    2 min answer stream-tablechangelogmaterialisationcdc
  6. Streaming Cost advanced

    A connected-vehicle telemetry pipeline's cost is growing faster than the fleet. Where does the cost go, and what reduces it?

    2 min answer athertelemetrycostfiltering
  7. Streaming Cost advanced

    A streaming pipeline's cost grows faster than its event volume. What are the drivers?

    1 min answer streaming-coststatepartitionsretention
  8. Streaming Cost advanced

    A streaming platform's cloud bill is dominated by a line item nobody recognises: inter-zone data transfer. Explain and fix.

    2 min answer finopsstreamingnetworking
  9. Streaming Joins advanced

    A job interval-joins click events to impression events with a two-hour window. To fix a parser bug the team resets only the click consumer's offsets to three days ago and lets the running job catch up. Walk through what happens, what the output looks like, and what stops it.

    3 min answer interval joinwatermarksreplaybackfill
  10. Streaming Joins advanced

    A pipeline must join two streams whose events arrive at different times. What makes streaming joins hard, and what are the options?

    2 min answer streaming-joinsstatewindowsenrichment
  11. Streaming & Real-Time Data advanced

    A delivery platform assigns each order to the nearest available driver as soon as the order is ready. Critique this.

    2 min answer doordashoptimisationmatchinglatency
  12. Streaming & Real-Time Data advanced

    A live platform computes real-time metrics during events where concurrency changes by an order of magnitude within minutes. What must the streaming architecture provide?

    2 min answer streaminglive-eventslagpartitioning