Imports github.com/confluentinc/confluent-kafka-go/kafka github.com/gogo/protobuf/gogoproto github.com/gogo/protobuf/proto github.com/golang/protobuf/ptypes/timestamp github.com/rcrowley/go-metrics github.com/sirupsen/logrus golang.org/x/time/rate Standard library imports context fmt time math math/rand