Kafka Fraud Detection Pipeline

Kafka 7.4 Spark 3.4 PySpark PostgreSQL 15

Click any component to explore · Use controls to simulate throughput

0
events sent
—
avg latency
0
fraud alerts
0.00%
fraud rate
Transaction generator 23 txn / sec Apache Kafka transactions topic keyed by user_id Spark streaming Stateless rules UDF Velocity window 60s sub-800ms latency foreachBatch sink PostgreSQL transactions (all) PostgreSQL fraud_alerts sent: 0 lag: — 0 rows 0 alerts

Click any component above to see implementation details.