Родительский диапазон не подключается в OpenTelemetry с Kafka и Java ⇐ JAVA

[Anonymous]

Я работаю с двумя службами Java, подключенными через Kafka, и интегрировал OpenTelemetry для распределенной трассировки. В Сервисе А я создаю родительский диапазон, а в сообщение Kafka включаю два строковых значения: трассировкуId и spanId.
Однако в Сервисе Б у меня возникают проблемы с использованием этих значений. значения для подключения нового диапазона к родительскому.
Вот что я пробовал в Сервисе B:

Код: Выделить всё

SpanContext spanContext = SpanContext.create(parentTraceId, parentSpanId, TraceFlags.getDefault(), TraceState.getDefault());

Span kafkaMessageSpan = otelTracer.spanBuilder("kafka-message2-processing")
.setParent(Context.current().with(Span.wrap(spanContext)))
.startSpan();

kafkaMessageSpan.end();

Значения ParentTraceId и ParentSpanId в журналах выглядят следующим образом:
parentTraceId: 5e3a44aa9817427c970800316ff717e7
parentSpanId: 91367512fa425dca
Чего мне не хватает? Любая помощь будет оценена по достоинству. Спасибо!

Я также пытался использовать createFromRemoteParent. но ничего не изменилось

Подробнее здесь: https://stackoverflow.com/questions/777 ... a-and-java