{"type":"excalidraw","version":2,"source":"https://AwesomeSystemDesign.dev","elements":[{"angle":0,"strokeColor":"#6577aa","backgroundColor":"#eef1fc","fillStyle":"solid","strokeWidth":1.5,"strokeStyle":"solid","roughness":0.7,"opacity":100,"version":1,"versionNonce":1,"isDeleted":false,"groupIds":["step-1"],"frameId":null,"roundness":null,"boundElements":[{"type":"text","id":"shape-1"}],"updated":0,"link":null,"locked":false,"id":"shape-0","type":"rectangle","seed":41,"x":466,"y":32,"width":390,"height":808.2,"customData":{"revealStep":1}},{"angle":0,"strokeColor":"#394557","backgroundColor":"transparent","fillStyle":"solid","strokeWidth":1.5,"strokeStyle":"solid","roughness":0.7,"opacity":100,"version":1,"versionNonce":1,"isDeleted":false,"groupIds":["step-1"],"frameId":null,"roundness":null,"boundElements":null,"updated":0,"link":null,"locked":false,"id":"shape-1","type":"text","seed":114,"x":486,"y":50,"width":350,"height":772.2,"fontSize":18,"fontFamily":1,"text":"Key Metrics:\n• Event throughput per topic\n(events/sec in, out)\n• Consumer lag per group (most\ncritical metric)\n• End-to-end event latency (publish →\nconsume)\n• DLQ depth per consumer group (>\n0 = problem)\n• Schema compatibility check failures\n(CI/CD)\n• Saga completion rate and duration\n• CDC connector lag (WAL position\nbehind)\n• Event store size and replay\nthroughput\n• Cross-service trace completion\nrate\n\nAlerts:\nRED — Consumer lag growing for >\n10 min (critical consumer)\nRED — DLQ depth > 0 for > 5 min\nRED — Saga stuck in\nCOMPENSATING for > 30 min\nRED — CDC connector disconnected\nfrom source DB\nWARN — Event throughput dropped >\n30% (producer issue?)\nWARN — Schema compatibility\nrejection in CI/CD\nWARN — Consumer processing latency\np99 > 1 second","originalText":"Key Metrics:\n• Event throughput per topic\n(events/sec in, out)\n• Consumer lag per group (most\ncritical metric)\n• End-to-end event latency (publish →\nconsume)\n• DLQ depth per consumer group (>\n0 = problem)\n• Schema compatibility check failures\n(CI/CD)\n• Saga completion rate and duration\n• CDC connector lag (WAL position\nbehind)\n• Event store size and replay\nthroughput\n• Cross-service trace completion\nrate\n\nAlerts:\nRED — Consumer lag growing for >\n10 min (critical consumer)\nRED — DLQ depth > 0 for > 5 min\nRED — Saga stuck in\nCOMPENSATING for > 30 min\nRED — CDC connector disconnected\nfrom source DB\nWARN — Event throughput dropped >\n30% (producer issue?)\nWARN — Schema compatibility\nrejection in CI/CD\nWARN — Consumer processing latency\np99 > 1 second","textAlign":"center","verticalAlign":"middle","containerId":"shape-0","lineHeight":1.3,"autoResize":false,"customData":{"revealStep":1}},{"angle":0,"strokeColor":"#628572","backgroundColor":"#edf5ee","fillStyle":"solid","strokeWidth":1.5,"strokeStyle":"solid","roughness":0.7,"opacity":100,"version":1,"versionNonce":1,"isDeleted":false,"groupIds":["step-2"],"frameId":null,"roundness":null,"boundElements":[{"type":"text","id":"shape-3"}],"updated":0,"link":null,"locked":false,"id":"shape-2","type":"rectangle","seed":187,"x":36,"y":32,"width":390,"height":1814.4,"customData":{"revealStep":2}},{"angle":0,"strokeColor":"#394557","backgroundColor":"transparent","fillStyle":"solid","strokeWidth":1.5,"strokeStyle":"solid","roughness":0.7,"opacity":100,"version":1,"versionNonce":1,"isDeleted":false,"groupIds":["step-2"],"frameId":null,"roundness":null,"boundElements":null,"updated":0,"link":null,"locked":false,"id":"shape-3","type":"text","seed":260,"x":56,"y":50,"width":350,"height":1778.4,"fontSize":18,"fontFamily":1,"text":"EVENT-DRIVEN PLATFORM\n\nPRODUCER SERVICES\n\nOrder Svc → [orders.*] Payment Svc\n→ [payments.*]\nUser Svc → [users.*] Inventory Svc →\n[inventory.*]\nShipping Svc → [shipping.*] Notification\nSvc → [notifications.*]\n\nEach service:\n• Transactional outbox (DB + poller\n→ Kafka)\n• Schema-validated serialization\n(Avro via Schema Registry)\n• trace_id / correlation_id\npropagation\n\n• KAFKA CLUSTER (100+ brokers)\n2,000 topics | 50,000 partitions |\nRF=3 | 5M events/sec 7-day hot\nretention | Tiered storage for\narchive KRaft consensus (no\nZooKeeper)\n\n• PLATFORM SERVICES\n• Schema Registry\n• 5K schemas\n• FULL compat.\n• Avro/Protobuf\n• CI/CD check\n• Event Catalog\n• Searchable\n• Owners/teams\n• Lineage graph\n• Consumer map\n• Saga Orchestrator\n• Checkout saga\n• Onboarding saga\n• Return saga\n• State persisted\n• Compensations\n• CDC Connectors (Debezium)\n• 30+ source DBs\n• WAL/binlog\n• Low overhead\n• DLQ Manager\n• Per-consumer DLQ\n• Replay UI\n• Auto-alerting\n• Bulk replay\n• Event Store (Event Sourcing)\n• Append-only\n• Snapshots\n• 10 TB\n\n• CONSUMER SERVICES\nCQRS Read Models\nOrder Dashboard (PostgreSQL) ←\n[orders.*, payments.*] Search Index\n(Elasticsearch) ← [products.*,\norders.*] Analytics Warehouse\n(ClickHouse) ← [ALL events]\nCustomer 360 View (MongoDB) ←\n[users.*, orders.*, support.*]\nReal-time Feed (Redis) ← [social.*,\ncontent.*]\nReactive Services\nPayment Svc ← [orders.placed] →\ncharge + publish Inventory Svc ←\n[orders.placed] → reserve + publish\nNotification Svc ← [orders.*,\npayments.*] → email/push Fraud\nDetection ← [payments.*] → score +\nflag","originalText":"EVENT-DRIVEN PLATFORM\n\nPRODUCER SERVICES\n\nOrder Svc → [orders.*] Payment Svc\n→ [payments.*]\nUser Svc → [users.*] Inventory Svc →\n[inventory.*]\nShipping Svc → [shipping.*] Notification\nSvc → [notifications.*]\n\nEach service:\n• Transactional outbox (DB + poller\n→ Kafka)\n• Schema-validated serialization\n(Avro via Schema Registry)\n• trace_id / correlation_id\npropagation\n\n• KAFKA CLUSTER (100+ brokers)\n2,000 topics | 50,000 partitions |\nRF=3 | 5M events/sec 7-day hot\nretention | Tiered storage for\narchive KRaft consensus (no\nZooKeeper)\n\n• PLATFORM SERVICES\n• Schema Registry\n• 5K schemas\n• FULL compat.\n• Avro/Protobuf\n• CI/CD check\n• Event Catalog\n• Searchable\n• Owners/teams\n• Lineage graph\n• Consumer map\n• Saga Orchestrator\n• Checkout saga\n• Onboarding saga\n• Return saga\n• State persisted\n• Compensations\n• CDC Connectors (Debezium)\n• 30+ source DBs\n• WAL/binlog\n• Low overhead\n• DLQ Manager\n• Per-consumer DLQ\n• Replay UI\n• Auto-alerting\n• Bulk replay\n• Event Store (Event Sourcing)\n• Append-only\n• Snapshots\n• 10 TB\n\n• CONSUMER SERVICES\nCQRS Read Models\nOrder Dashboard (PostgreSQL) ←\n[orders.*, payments.*] Search Index\n(Elasticsearch) ← [products.*,\norders.*] Analytics Warehouse\n(ClickHouse) ← [ALL events]\nCustomer 360 View (MongoDB) ←\n[users.*, orders.*, support.*]\nReal-time Feed (Redis) ← [social.*,\ncontent.*]\nReactive Services\nPayment Svc ← [orders.placed] →\ncharge + publish Inventory Svc ←\n[orders.placed] → reserve + publish\nNotification Svc ← [orders.*,\npayments.*] → email/push Fraud\nDetection ← [payments.*] → score +\nflag","textAlign":"center","verticalAlign":"middle","containerId":"shape-2","lineHeight":1.3,"autoResize":false,"customData":{"revealStep":2}},{"angle":0,"strokeColor":"#a68a53","backgroundColor":"#fff7e6","fillStyle":"solid","strokeWidth":1.5,"strokeStyle":"solid","roughness":0.7,"opacity":100,"version":1,"versionNonce":1,"isDeleted":false,"groupIds":["step-3"],"frameId":null,"roundness":null,"boundElements":[{"type":"text","id":"shape-5"}],"updated":0,"link":null,"locked":false,"id":"shape-4","type":"rectangle","seed":333,"x":36,"y":1886.4,"width":420,"height":68,"customData":{"revealStep":3}},{"angle":0,"strokeColor":"#394557","backgroundColor":"transparent","fillStyle":"solid","strokeWidth":1.5,"strokeStyle":"solid","roughness":0.7,"opacity":100,"version":1,"versionNonce":1,"isDeleted":false,"groupIds":["step-3"],"frameId":null,"roundness":null,"boundElements":null,"updated":0,"link":null,"locked":false,"id":"shape-5","type":"text","seed":406,"x":56,"y":1909.3500000000001,"width":380,"height":22.1,"fontSize":17,"fontFamily":1,"text":"Monitoring:","originalText":"Monitoring:","textAlign":"left","verticalAlign":"middle","containerId":"shape-4","lineHeight":1.3,"autoResize":false,"customData":{"revealStep":3}}],"appState":{"viewBackgroundColor":"#fbfbf8","gridSize":null},"files":{}}