Apache Kafka is a distributed publish-subscribe messaging system and a robust queue that can handle a high volume of data and enables you to pass messages from one end-point to another. Kafka is suitable for both offline and online message consumption. Kafka messages are persisted on the disk and replicated within the cluster to prevent data loss.
This repo demostrates the simulation of kafka built in python.
Visual Studio Code
Change your directory to the folders that include the start files.
Run "pip install -r .\requirements.txt"
To start the warden, run start_warden.py
To start a broker, run start_broker.py
To start a consumer, run start_consumer.py
To start a publisher, run start_publisher.py
To start the test app, run start_test_app.py