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