golang-kafka-example

golang-kafka-example copied to clipboard

Kafka Golang Example

Example code for my blog post.

Steps to run:

1. Clone this repository
2. Install dependencies : go mod tidy && go mod vendor
3. Make sure Kafka is running, and change the value of brokerAddress to the address of you Kafka instance
4. Run the code : go run main.go

You can see how to install and run a Kafka cluster in my other tutorial