Need to be tested in a distributed environment. Currently all the changes have not be tested. OpenCV needs to be installed to every machine that streams video into Apache Kafka.
python run.py -t <topic> -p <producers> -f <video.mp4> -m <machines> -b <brokers> -a master
Using the above command starts the master producer. In case an agent producer needs to be started the only parameter that needs to be passed is the type: -a agent
Need to be tested in a distributed environment. Currently all the changes have not be tested. OpenCV needs to be installed to every machine that streams video into Apache Kafka.
python run.py -t <topic> -p <producers> -f <video.mp4> -m <machines> -b <brokers> -a masterUsing the above command starts the master producer. In case an agent producer needs to be started the only parameter that needs to be passed is the type:
-a agent