Real-time data streaming pipeline built with modern data engineering tools for scalable ingestion, processing, transformation, and analytics of continuous data streams.
Mini project for the course Database Technologies (UE22CS343BB3)
Built a streaming fraud detection system with Apache Kafka and Python. Deployed a Kafka cluster via Docker Compose, implemented a transaction generator and fraud detector using kafka-python, and routed suspicious transactions to separate topics for real-time monitoring. Demonstrates event streaming, producers, consumers, and containerization.
A boilerplate of consumer-producer where the producer is a camera capture.
Homework for the Computing Systems Architecture course @ ACS, UPB 2020
Apache Kafka
Add a description, image, and links to the producers topic page so that developers can more easily learn about it.
To associate your repository with the producers topic, visit your repo's landing page and select "manage topics."