code: func NewReporter(address []string, options ...ReporterOption) (reporter.Reporter, error) {
  	r := &kafkaReporter{
  		logger:     log.New(os.Stderr, "", log.LstdFlags),
  		topic:      defaultKafkaTopic,
  		serializer: reporter.JSONSerializer{},
  	}
  
  	for _, option := range options {
  		option(r)
  	}
  	if r.producer == nil {
  		p, err := sarama.NewAsyncProducer(address, nil)
  		if err != nil {
  			return nil, err
  		}
  		r.producer = p
  	}
  
  	go r.logErrors()
  
  	return r, nil
  }
docs: // NewReporter returns a new Kafka-backed Reporter. address should be a slice of
  // TCP endpoints of the form "host:port".