This project is a simple example of using the Kafka message broker with Golang applications. This example implements a cluster of two Kafka servers - they have a common topic and 2 partitions that are shared between the servers, in addition one server stores replications of the other and can completely replace it in case of failure. Two consumers have been implemented on Go, as well as a produser with an HTTP server responsible for sending messages to Kafka.
To use the Kafka UI after running the service via Docker, go to http://localhost:8090
IMPORTANT If you have made changes to the configuration files, check them against the parameters specified in docker-compose.yml
To start a project using Docker, run the following command from the root of the project:
docker-compose up -dTo stop, use:
docker-compose downUse the following commands to start the producer and consumers:
go run cmd/producer/main.gogo run cmd/consumer/main.gogo run cmd/consumer2/main.goPOST /message
{
"message": "Hello World!"
}