A simple notification implementation built with Kafka and Go
-
Git
-
Docker
- Clone the Repo
git clone git@github.com:VinukaThejana/notifications.git && cd notifications
- Run the Kafka Broker and the Kafka management UI with docker.
cd init/ && docker compose up -d
- Run the Producer to produce new notifications.
go run cmd/producer/producer.go
- Run the consumer to consume notifications in real time as the user submits them.
go run cmd/consumer/consumer.go