consumer-main.go

func main() {
	startConsumerGroup([]string{"kafka:9092"})

	select {}
}

func startConsumerGroup(brokerList []string) {
	consumerGroupHandler := Consumer{}
	// Wrap instrumentation
	handler := otelsarama.WrapConsumerGroupHandler(&consumerGroupHandler)

	config := sarama.NewConfig()
	config.Version = sarama.V2_5_0_0
	config.Consumer.Offsets.Initial = sarama.OffsetOldest

	// Create consumer group
	consumerGroup, err := sarama.NewConsumerGroup(brokerList, "example", config)
	if err != nil {
		log.Fatalln("Failed to start sarama consumer group:", err)
	}

	err = consumerGroup.Consume(context.Background(), []string{"example-topic"}, handler)
	if err != nil {
		log.Fatalln("Failed to consume via handler:", err)
	}
}