Example code for my blog post.
Steps to run:
- Clone this repository
- Install dependencies :
go mod tidy && go mod vendor
- Make sure Kafka is running, and change the value of
brokerAddress
to the address of you Kafka instance - Run the code :
go run main.go
You can see how to install and run a Kafka cluster in my other tutorial