Imports github.com/go-sql-driver/mysql github.com/segmentio/kafka-go/snappy github.com/segmentio/kafka-go github.com/golang/glog Standard library imports database/sql context encoding/json flag fmt io/ioutil net/http strconv strings time