Создание контекста трассировки из строки в Java SDK открытой телеметрии

у меня есть конвейер ETL с 5 шагами. Каждый шаг может выполняться в другом потоке и другом приложении.

Это очень затрудняет передачу контекста трассировки отеля через все, потому что внутренние компоненты мне недоступны, поэтому все, к чему у меня есть доступ, — это этапы обработки.

Я ищу способ построить контекст трассировки только на основе одного идентификатора, который однозначно идентифицирует полное прохождение всех 5 шагов одной записи данных.

Пример:

Я ищу код, который работает примерно так:

public class Step1 {
    public void execute(DataPackage obj){
         var otelContext = SpanContext.create(
              TraceId.fromBytes(obj.getUniqueId().getBytes()),
              SpanId.fromBytes(processorName.getBytes()),
              TraceFlags.getDefault(),
              TraceState.getDefault()
         );

         var wrap = Span.wrap(otelContext);

         var with = Context.root().with(wrap);
  
         var span = tracer.spanBuilder("Step1").setParent(with).startSpan();
         CompletableFuture.runAsync(() -> { /* the code is here*/ }).whenComplete((c1, exception) -> {
         if (exception != null) {
           span.recordException(exception);
         } else {
           span.end();
         }
       });
    }
}

Происходит следующее: начало и конец диапазона являются отдельными и не находятся в одном и том же контексте трассировки. Значит, здесь что-то пошло не так

Сейчас я пытаюсь создать контекст вручную:

    var paddedArray = new byte[16];

    var originalArray = context.getId().getBytes();
    System.arraycopy(originalArray, 0, paddedArray, 16 - originalArray.length, originalArray.length);

    var wrap = Span.wrap(SpanContext.createFromRemoteParent(
        TraceId.fromBytes(paddedArray),
        SpanId.fromBytes(paddedArray),
        TraceFlags.getDefault(),
        TraceState.getDefault())
    );
    var otelContext = Context.root().with(wrap);

    var startSpan = tracer.spanBuilder(context.getId())
        .setParent(otelContext)
        .startSpan();

Проблема, с которой я столкнулся ранее, заключалась в том, что массив входных байтов имел неправильную длину. Теперь я это исправил, но следующая проблема в том, что в jaeger это вообще не отображается.

Я подозреваю, что это потому, что контекст не был создан в jaeger, потому что здесь всегда предполагается, что контекст существовал ранее. Есть ли способ всегда «обновлять» контекст?

У меня действительно нет возможности узнать, когда следует создавать контекст или нет, поскольку конвейер etl 1 может работать до конвейера etl 2 или наоборот.