Imports github.com/Shopify/sarama github.com/bsm/sarama-cluster github.com/micro/go-log github.com/micro/go-micro/broker github.com/micro/go-micro/codec github.com/micro/go-micro/codec/json github.com/silenceper/pool gopkg.in/bsm/sarama-cluster.v2 Standard library imports crypto/tls crypto/x509 io/ioutil log os os/signal plugins/broker/kafka sync time