Simple Kafka pub/sub example written in Go
docker-compose up -d
If you want to scale Kafka brokers to 4:
docker-compose scale kafka=4
cd pub
go run pub.go -topic=t1 -zk=192.168.99.100:2181
cd sub
go run sub.go -topic=t1 -zk=192.168.99.100:2181
For consuming as in another consumer group:
go run sub.go -topic=t1 -zk=192.168.99.100:2181 -group=group02