Distributed Multi-video processing pipeline with Python and Confluent Kafka

Stream and process multiple videos in near real time using Kafka. The video frames are processed and a machine learning model does inference on them and the results are stored in a mongodb database.

Install Dependencies

pip install -r requirements.txt

Run the Application

Before Running, you have to start MongoDB and Kafka Server Instance.

Run Producer Application

python producer_app.py

Run Consumer Application

python consumer_app.py

Associated Article

you can go through the medium article for more details