This repository is basically a Message Broker Service using Apache Kafka for Image Recognition Model.
- Setup and Installation
- Requirements
- How to use
To use this project, clone the repo using the following command:
git clone https://github.com/makaveli10/fashion-mnist-kafka-app.git
- In order to use aerospike db download, setup and install aerospike from here
- In order to use the Kafka, you are required to setup and start Apache Kafka Zookeeper and Kafka Server. Follow this guide.
- Install the requirements:
python3 -m pip install requirements.txt
- To train the model, use:
python3 train.py
- To run the application server with ImageStream Consumer and Result Producer use:
python3 app.py
- [Only for Testing] This will basically stream test set images to a topic which will be consumed by the application server ImageStream Consumer. After consuming the images streams server will try to publish results under a topic and Result consumer on the client side will try and consume those results. To run client side ImageStream Producer and Result Consumer run:
python3 api.py