docker-compose -f zk-kafka-single.yml up -d

docker-compose -f elastic-kibana-single.yml up -d

python3 -m venv venv
. venv/bin/activate
pip install -r requirements.txt

celery -A producer.app worker --beat --loglevel=info --scheduler=cron -s /app/celerybeat-schedule"

python consumer.py

python main.py

curl -X GET 'http://localhost:5000/search?query={"text":"Hi"}'

curl -X POST \
 -H "Content-Type: application/json" \
 -d '{
   "doc_id": "q8FBDokBeVjFa6NEfDUi",
   "tags": ["1", "2", "3"]
 }' \
 http://localhost:5000/tag