CreateSpan for each tracing layer.

CreateSpanKafkaConsumerCtx create span for tracing message.

NewConsumerMessageCarrier creates a new ConsumerMessageCarrier.

NewProducerMessageCarrier creates a new ProducerMessageCarrier.

TracerProvider returns an OpenTelemetry TracerProvider configured to use the Otel exporter that will send spans to the provided url.

WithPropagators specifies propagators to use for extracting information from the HTTP requests.

WithTracerProvider specifies a tracer provider to use for creating a tracer.

WrapKafkaProducer wraps a sarama.SyncProducer so that all produced messages are traced.

ConsumerMessageCarrier injects and extracts traces from a sarama.ConsumerMessage.

ProducerMessageCarrier injects and extracts traces from a sarama.ProducerMessage.

Option interface used for setting optional config properties.