Problems / Async and streaming, medium

Duplicate charges

Payment events go through a queue that delivers at least once. Some acknowledgements are lost, so some customers are charged twice.

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

Your goals

No duplicate side effects, success ≥ 99%.

The traffic

500 requests a second for 30 seconds: 100% webhook (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 Webhook API.Layer 4 balancers route by IP and port; layer 7 balancers read HTTP and can route by path or header.–
Webhook APIApp serviceLoad balancer forwards to it.Calls Payment queue (publishes).Little's law: throughput ≈ concurrency ÷ latency. 200 slots at 50 ms serve about 4,000 req/s.2 replicas × 100 slots · timeout 1.0 s
Payment queueMessage queueWebhook API publishes to it.Calls Payment worker.If a consumer does not finish within the visibility timeout, the message is delivered again.–
Payment workerWorkerPayment queue consumes from it.Queues deliver at least once, so a worker can see the same message twice.64 concurrent jobs

Hints

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

Hint 1

At-least-once means duplicates will happen.

Hint 2

Make the worker safe to run twice.

One way to solve it

Store an idempotency key with each charge so redeliveries are skipped.

More async and streaming problems