init-producer.go

func init() {
	config := sarama.NewConfig()
	config.Version = sarama.V2_5_0_0
	// So we can know the partition and offset of messages.
	config.Producer.Return.Successes = true

	var err error
	producer, err = sarama.NewAsyncProducer([]string{"kafka:9092"}, config)
	if err != nil {
		log.Fatal().Err(err).Msg("Failed to start Sarama producer")
	}

	// Wrap instrumentation
	producer = otelsarama.WrapAsyncProducer(config, producer)

	// We will log to STDOUT if we're not able to produce messages.
	go func() {
		for err := range producer.Errors() {
			fmt.Println("Failed to write message:", err)
		}
	}()
}