Apache Kafka Example on Go

This is a simple repo to use Apache Kafka with Go, the code demo is based on a chat via console line.

The code is divided into two part a client and a server.

Run Apache Kafka

The docker-compose.yml is based on gist by Matt Howlett

To run:

$ MY_IP=your-ip docker-compose up

If we want to create a topic, like fogo-chat you must run:

$ docker run --net=host --rm confluentinc/cp-kafka:5.0.0 kafka-topics --create --topic fogo-chat --partitions 4 --replication-factor 2 --if-not-exists --zookeeper localhost:32181

This command creates a topic named fogo-chat with 4 partitions and replication factor of 2.

Run the server

The default host is http://localhost:8080, you can change this configuration on .env file

make server-run

Run the clients

You can run as many clients as you want, executing this:

make client-run