Imports github.com/confluentinc/confluent-kafka-go/kafka github.com/lib/pq Standard library imports bufio container/list database/sql fmt io io/ioutil os os/exec strconv sync time