Problems / Async and streaming, hard

Orders: lost events and double emails

The order API writes the order, then publishes an event (dual write). At 10 s the queue is down for 5 seconds. The workers that send confirmation emails lose 2% of their acknowledgements and are not idempotent.

Free to open. Runs in your browser, no sign-up.

Your goals

No lost events, no duplicate side effects, success ≥ 99%.

The traffic

600 requests a second for 30 seconds: 100% submit (writes).

The system

What each component does in this design, and what calls it. The simulator mimics each one from these settings.

ComponentIts job hereSettings
Load balancerLoad balancerTraffic enters here.Calls API.Layer 4 balancers route by IP and port; layer 7 balancers read HTTP and can route by path or header.–
APIApp serviceLoad balancer forwards to it.Calls Orders DB, Job queue (SQS) (publishes).Little's law: throughput ≈ concurrency ÷ latency. 200 slots at 50 ms serve about 4,000 req/s.3 replicas × 200 slots · timeout 1.0 s
Orders DBSQL databaseAPI calls it.Postgres runs one process per connection, which is why poolers like PgBouncer sit in front of busy databases.8 vCPU · 60 connections
Job queue (SQS)Message queueAPI publishes to it.Calls Workers.If a consumer does not finish within the visibility timeout, the message is delivered again.–
WorkersWorkerJob queue (SQS) consumes from it.Calls Results DB.Queues deliver at least once, so a worker can see the same message twice.16 concurrent jobs
Results DBSQL databaseWorkers calls it.Postgres runs one process per connection, which is why poolers like PgBouncer sit in front of busy databases.8 vCPU · 60 connections

Hints

Try it first. Open one hint at a time if you get stuck.

Hint 1

Two contracts are missing: one on the API, one on the workers.

Hint 2

Events vanish when the publish fails after the write; emails repeat when a message is redelivered.

Hint 3

A transactional outbox on the API and an idempotency key on the workers.

One way to solve it

Switch the API to a transactional outbox and give the workers an idempotency-key registry.

More async and streaming problems