Lost Context propagation SpringKafka / kafka client - manual instrumentation

[dimitri995]

Hello,

I am using the instrumentation of Spring Kafka but I can't propagate the context in this flow :
producer1 -> consumer1 (become producer2)-> consumer2.

I would want to have 1 trace ID but I got 2. It seems I lost the context... I got traceparent in headers of the message until the consumer1 became the producer2, it seems to overwrite the existing traceparent.

Have you any idea why it's happening ?

OpenTelemetry is integrated in a lib used by our applications.

Thanks for your time.

Regards,

Dimitri

[dimitri995]

I fixed it,
I was using the interceptor class for the listener, see below :

I am using SpringKafka, so I need to use this interceptor way to propagate context correctly :

Regards,

[mateuszrzeszutek]

This might be useful to you: here's an example of using library instrumentation in a (test) spring application to instrument kafka: https://github.com/open-telemetry/opentelemetry-java-instrumentation/blob/main/instrumentation/spring/spring-kafka-2.7/library/src/test/java/io/opentelemetry/instrumentation/spring/kafka/v2_7/SpringKafkaNoReceiveTelemetryTest.java