AWSKafkaClickHouseNext.js 14FastAPITemporalPulumiOpenTelemetry
Overview
Real-time enterprise customer intelligence platform: teams see live which customers are at risk of churning. AI continuously analyzes behavior, computes a health score every 30 seconds, and triggers alerts automatically. The system handles 15,000 events per second.
Technical details
npm SDK → FastAPI ingestion → Kafka (AWS MSK) → Stream Processor → ClickHouse (<80ms over 30 days). Churn alerts → Temporal workflows → AI (Gemini 2.5 Flash + Claude Opus 4.6) → Next.js 14 dashboard. 66 AWS resources via Pulumi TypeScript. OpenTelemetry → X-Ray + CloudWatch. ~15,000 events/s (ECS + MSK, 1000 VUs).
15k/s
Events throughput
<80ms
30-day queries
66
AWS resources