Kafka Go Application
This project exemplifies a straightforward application showcasing the process of producing and consuming messages through Kafka in Go.
Prerequisites
Prior to initiation, it is imperative to verify that your system meets the prescribed prerequisites by ensuring the installation of the following requirements:
- Latest version of Go (1.17 or higher).
- Recent version of Apache Kafka (2.8.0 or higher).
- Recent version of kafka-go (0.4.40 or higher)
Installation
- Clone the repository:
git clone https://github.com/mostwelcome/go-kafka.git
- Navigate to the cloned repository:
cd your_repository
- Install dependencies:
go mod tidy
Usage
-
Start your Kafka and Zookeeper servers.
-
Run the producer to send messages to Kafka:
go run kafka_producer.go
-
In a separate terminal, run the consumer to read messages from Kafka:
go run kafka_consumer.go
Contribution
- Fork this repository.
- Create a branch:
git checkout -b <branch_name>.
- Make your changes and commit them:
git commit -m '<commit_message>'
- Push to the original branch:
git push origin <project>/<location>
- Create the pull request using relevant title, description and on-point commit messages.
To initiate contact with me regarding this application, feel free to reach out via email.