Kafka in Golang Realtime Consumer go run consumer.go Message Producer go run producer.go Up and Running KFKA docker-compose up