This repository contains a Python implementation of a distributed video streaming system that relays on Apache Kafka. Moreover, we provide a performance tool.
In this project we will use confluentinc/cp-kafka:5.2.1
.
For suggested hardware requirements of Apache Kafka please have a look here.
In this project we will use python-kafka, note that other Apache Kafka Python clients are available, e.g., confluent-kafka-python, pykafka, etc.
python 3.7
virtualenv
docker-compose
opencv
Create a virualenv and install requirements
virtualenv --python=python3.7 env
. env/bin/activate
pip install -r requirements.txt
Deploy Apache Kafka by using docker-compose
docker-compose up -d
Run the producer:
python producer.py video/coverr-golden-gate-bridge.mp4
Run the consumer:
python consumer.py
python performance.py