Imports github.com/Shopify/sarama fluux.io/kafka/auth Standard library imports flag fmt log os sync os/signal