实时订单总线 + CDC 数仓

点击节点查看职责与配置 · 端到端动画 · 故障演练

系统拓扑

━━ 链路 A：业务事件总线 ━━
👤 User
HTTP POST
→
⚡ OrderService
FastAPI + Producer
🗄 MySQL
orders 表
→
📨 orders.events
12 分区 · RF=3
→
🛡 Risk
group: risk
📦 Inventory
group: inventory
🔔 Notify
group: notify
━━ 链路 B：CDC 数仓 ━━
🗄 MySQL binlog
orders 表
→
🔄 Debezium
MySQL Source
→
📨 cdc.mysql.orders
3 分区 · 30天
→
🌊 Streams
faust-streaming
📨 orders.enriched
3 分区
→
🔁 CK Sink
Kafka Connect
📊 ClickHouse
orders_dwd
━━ 公共组件 ━━
📋 Schema Registry
BACKWARD_TRANSITIVE
💀 orders.events.dlq
死信队列
📈 Prom + Grafana
JMX Exporter

节点详情

点击左侧任意节点查看说明

动画 / 演练