Imports github.com/confluentinc/confluent-kafka-go/kafka github.com/gofrs/uuid Standard library imports bufio context encoding/json errors fmt log os os/signal strings sync syscall time