Public payments company

A medium Pipeline Design interview practice problem on DataDriven. Write and execute real pipeline design code with instant grading.

Domain

Pipeline Design

Difficulty

medium

Problem

Public payments company. The financial-close streaming aggregator was blamed last week for a duplicate-revenue incident during a Kafka rebalance; reports for two days had to be reissued. The canvas shows the dual-write antipattern, a Flink aggregator whose engine-level exactly-once does not extend to its sink, and a plain Snowflake destination. The CFO needs exact reconciliation against a bank settlement file at quarter close. Apply the section's six-step synthesis so every boundary is effectively-once and the contract is documented.

Practice This Problem

Solve this Pipeline Design problem with real code execution. DataDriven runs your solution and grades it automatically.