This project is a Kafka consumer written in Go that listens for messages on a specified topic ("comments") and processes them. It handles graceful shutdowns and logs the received messages along with their count.
- Ensure you have Go installed on your machine. You can download it from golang.org.
- Clone the repository:
git clone <repository-url> cd <repository-directory>
- Install the required dependencies:
go mod tidy
- Start your Kafka broker and ensure it is running.
- Run the worker:
bash go run worker/worker.go - The worker will start consuming messages from the "comments" topic. It will log the received messages and their count.
This project is licensed under the MIT License - see the LICENSE file for details.