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