kafka-ml-training

Run Kafka

docker-compose up

Install Libraries

python -m pip install kafka-python river

Run the Producer

python producer.py

Train a Model Using a Kafka Consumer

python consumer.py