Imports github.com/confluentinc/confluent-kafka-go/kafka github.com/secmask/go-redisproto github.com/urfave/cli Standard library imports os/signal bufio bytes context encoding/json errors fmt log net os strconv strings sync sync/atomic syscall time