
Real-Time Transaction Monitoring and Payment Intelligence Platform
50,000+ events per day, sub-second end-to-end latency, exactly-once delivery
I architected and developed an event-driven platform that watches payments as they happen and flags fraud within sub-second latency. Card and gateway events from Stripe, payment gateways, and internal services land in Apache Kafka, and Apache Flink runs the fraud and enrichment logic with sliding-window pattern detection, idempotency keys, and a customer-metadata join against PostgreSQL. Results fan out to a live WebSocket dashboard, a Snowflake warehouse for compliance history, and banking webhook callbacks, with failed events routed to a dead-letter queue. It runs multi-AZ with exactly-once delivery, S3 checkpointing for recovery, and Prometheus and Grafana for observability.
- Apache Kafka
- Apache Flink
- Snowflake
- PostgreSQL
- FastAPI
- WebSocket
- Prometheus







