Here's how to setup Kafka as a pub/sub engine for Alexander Shuiskov's excellent Microservices with Go, and how to create a producer and consumer for your instance in a CLI
running Docker Compose
- create a Docker Compose YAML file in cmd/ratingingester
run Kafka in a Docker container (from movieapp/src/cmd/ratingingester):
- docker-compose -d up
- docker exec -it kafka /bin/sh