Fraud Detector Pipeline

A pipeline designed using Apache Kafka to segregate fraudulent/ legitimate transactions.

Features

• Bifurcate transactions into two types (fraudulent/ legitimate)_
• Provides insights over a socketio dashboard

Services

Dashboard

Flask SocketIO Dashboard to provide real time insights.

Detector

Service to segregate the transactions on receiving them from the subscribed Kafka topic.

Generator (for testing)

Service to generate random transactions and populate the Kafka topic.

References

https://florimond.dev/blog/articles/2018/09/building-a-streaming-fraud-detection-system-with-kafka-and-python/