Skip to content

Implementation of Apache Kafka, a popular distributed streaming & messaging service.

Notifications You must be signed in to change notification settings

nkilm/yet-another-kafka

Repository files navigation

Yet-Another-Kafka

Built with Flask and Pika


Pre-requisites

How to setup locally?

After git clone and cd to project folder

  • Create Virtual Environment
  • Install requirements
pip install -r requirements.txt
  • Start zookeeper
make start

# OR

# without make - from project's root directory
python yak/zoo_keeper.py
  • Starting the consumer and producer
# listens continuously
python testing_consumer.py

# on new terminal
python testing_producer.py

NOTE: operations.log is only for reference.

About

Implementation of Apache Kafka, a popular distributed streaming & messaging service.

Topics

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published