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

Canonical URL: <https://datadriven.io/problems/a-streaming-consumer-throws-on-a-malformed-event-restarts-5e3ca0d4>

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.

## Related

- [All practice problems](https://datadriven.io/problems)
- [Mock interview mode](https://datadriven.io/interview/a-streaming-consumer-throws-on-a-malformed-event-restarts-5e3ca0d4)
- [System Design Interview Questions](https://datadriven.io/data-engineering-system-design)
- [Data Engineering Interview Prep Guide](https://datadriven.io/data-engineer-interview-prep)
- [Daily Challenge](https://datadriven.io/daily)

---

Source: DataDriven (https://datadriven.io). 100% free data engineering interview prep. Live code execution against Postgres 16, Python 3.11, and Spark sandboxes. No paywall, no premium tier, no signup gate.