A streaming consumer throws on a malformed event, restarts, replays the same poison event, and throw

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

A streaming consumer throws on a malformed event, restarts, replays the same poison event, and throws again. The whole fraud pipeline is wedged behind one bad record. Design the path so bad events step aside and the good ones keep flowing.

Practice This Problem

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