Imports github.com/Shopify/sarama github.com/bsm/sarama-cluster github.com/confluentinc/confluent-kafka-go/kafka github.com/satori/go.uuid Standard library imports encoding/json errors fmt io/ioutil strings time