Producer and Consumer for Kafka in Go