-
Download Kafka Scala 2.13 at Apache Kafka
-
Extract the folder inside the project
-
Start Zookeeper:
bin/zookeeper-server-start.sh config/zookeeper.properties
-
Start Kafka:
bin/kafka-server-start.sh config/server.properties
-
Go to /apps and start consumers:
python3 email_service.py python3 fraud_detector_service.py python3 log_service.py
-
Go to /apps and try sendind orders:
python3 new_order_service.py
-
Start Kafka Broker and UI:
docker-compose up -d
-
See the process running at Kafka UI
-
Go to /apps and start consumers:
python3 email_service.py python3 fraud_detector_service.py python3 log_service.py
-
Go to /apps and try sendind orders:
python3 new_order_service.py