Quarkus with Microprofile OpenTracing distributed tracing doesn't work

Generally workaround looks like that: we have pre processor and post processor for rest requests which store uber-trace-id in thread local via org.jboss.logging.MDC

<dependency>
    <groupId>org.jboss.logging</groupId>
    <artifactId>jboss-logging</artifactId>
    <version>3.4.1.Final</version>
</dependency>

and then in rest client we are just using this thread local value.

Code look like that: Pre matching is reading and storing ubraTraceId if exist in incoming request header

import java.nio.charset.StandardCharsets;
import javax.annotation.Priority;
import javax.ws.rs.container.ContainerRequestContext;
import javax.ws.rs.container.ContainerRequestFilter;
import javax.ws.rs.container.PreMatching;
import javax.ws.rs.ext.Provider;
...

@Provider
@PreMatching
@Priority(1)
public class PreMatchingTraceIdRequestFilter implements ContainerRequestFilter {

...


    @Override
    public void filter(ContainerRequestContext containerRequestContext) {
        // Remove uberTraceID from the logging context which can contain a previous request.
        // Additionally done in ClearLoggingContextWriterInterceptor
        LoggingUtil.clearContext();
        String jaegerUberTraceID = decode(containerRequestContext.getHeaderString(HTTP_HEADER_UBER_TRACE_ID));
        if (nonNull(jaegerUberTraceID)) {
            LoggingUtil.setUberTraceId(jaegerUberTraceID);
            //here some logging
        }
        // else case handled by the PostMatchingTraceIdRequestFilter later in the jax-rs request processing chain.
    }

    private static String decode(String headerString) {
        return StringHelper.decode(String.valueOf(headerString), StandardCharsets.UTF_8.name());
    }
}

and in post matching we are would like to newly generated uberTraceId from Jaeger tracer and store it.

import io.jaegertracing.internal.JaegerSpanContext;
import io.opentracing.Tracer;
import javax.annotation.Priority;
import javax.inject.Inject;
import javax.ws.rs.Priorities;
import javax.ws.rs.container.ContainerRequestContext;
import javax.ws.rs.container.ContainerRequestFilter;
import javax.ws.rs.ext.Provider;
import static java.util.Objects.nonNull;

@Provider
// IMPORTANT: don't give this filter a higher priority!
// Cannot be invoked earlier because the Jaeger Client has to initialize the span for this request first.
// Tests revealed that the span is not initialized yet if this filter is given a higher priority!
@Priority(Priorities.USER)
public class PostMatchingTraceIdRequestFilter implements ContainerRequestFilter {

    private Tracer tracer;
    
    @Inject
    public void setTracer(Tracer tracer) {
        this.tracer = tracer;
    }

    @Override
    public void filter(ContainerRequestContext containerRequestContext) {
        String jaegerUberTraceId = getJaegerUberTraceID();
        if (nonNull(jaegerUberTraceId)) {
            LoggingUtil.setUberTraceId(jaegerUberTraceId);
             // here some logging
        }
        // No else since an missing active span on Tracer can happen more often than you think:
        // using @Traced(false) for example suppresses the generation of a new span
    }

    private String getJaegerUberTraceID() {
        String uberTraceId = null;
        if (nonNull(tracer) && nonNull(tracer.activeSpan())) {
            JaegerSpanContext spanContext = (JaegerSpanContext) tracer.activeSpan().context();
            uberTraceId =
                    new StringBuilder()
                            .append(spanContext.getTraceId())
                            .append(UBER_TRACE_ID_SEPARATOR)
                            .append(decode(spanContext.getSpanId()))
                            .append(UBER_TRACE_ID_SEPARATOR)
                            .append(decode(spanContext.getParentId()))
                            .append(UBER_TRACE_ID_SEPARATOR)
                            .append(spanContext.getFlags())
                            .toString();
        }
        return uberTraceId;
    }

    private static String decode(long longValue) {
        return Long.toHexString(longValue);
    }
}

LogginUtil is just wrapper for MDC from jboss logging. and it does

    public static void clearContext() {
        MDC.clear();
    }

    public static void setUberTraceId(String uberTraceId) {
        MDC.put(MDC_UBER_TRACE_ID, StringUtils.defaultIfEmpty(uberTraceId, StringUtils.EMPTY));
    }
    public static String getUberTraceId() {
        return (String) MDC.get(MDC_UBER_TRACE_ID);
    }
    public static String getUberTraceIdAndRemoveFromContext() {
        final String traceId = getUberTraceId();
        clearContext();
        return traceId;
    }

and finally rest client, here is just reading uberTraceId from thread local (via MDC)

import javax.ws.rs.client.ClientBuilder;
import org.eclipse.microprofile.opentracing.ClientTracingRegistrar;

...
    protected void addUberTraceIdHeader(Invocation.Builder builder) {
        String uberTraceId = LoggingUtil.getUberTraceId();
        if (isNotBlank(uberTraceId)) {
            builder.header(TraceExtractor.HTTP_HEADER_UBER_TRACE_ID, uberTraceId);
        } else {
            throw new IllegalStateException("Lack of uber trace id");
        }
    }