OpenTelemetry splunkkafka tracing example (confluent-kafka-go)

splunkkafka.go

// Produce (context to kafka message header)
  	propagators := propagation.TraceContext{}
	propagators.Inject(ctx, splunkkafka.NewMessageCarrier(msg))

	err := producer.Produce(msg, deliveryChan)


// Consume (kafka message headers to context)
  	message, err := client.ReadMessage(1 * time.Second)

	propagators := propagation.TraceContext{}
	ctx = propagators.Extract(ctx, splunkkafka.NewMessageCarrier(message))