LMAX Disruptor implemented with Runnable Thread not propagating traces for Handler events

[sulthans]

Running lmax disruptor with Runnable intreface, in the run method kafka messages are consumed and published to another topics with event handlers.
In LMAX ringbuffer event Handlers trace context is not porpagating, I have added manual instrumentation but still not propagating in handlers and kafka topics. Do i need to this in all Handler, how to achieve it?

I am trying to use from the reference- https://github.com/open-telemetry/opentelemetry-java/blob/a55e9b6440057fb50db9908ec072086a7a4b3c95/context/src/main/java/io/opentelemetry/context/Context.java , but couldn't implement Runnable here.

(Scope scope = parentContext.makeCurrent()) { childSpan = tracer.spanBuilder("child-span").startSpan();

Sharing sample code reference,

final Tracer tracer = GlobalOpenTelemetry.getTracer("lmax-disruptor");
public void initialize() { 
//
    disruptor.start();
}

public void run() {
        while (true) {
            Span parentSpan = tracer.spanBuilder("parent-span").startSpan();
             if (!records.isEmpty()) {
                try (Scope scope = parentSpan.makeCurrent()) {
                    consume(records, Context.current());
                }
                finally {
                    parentSpan.end();
                }
            }
            if (!isLastMessageProcessed()) {
                Thread.sleep(100);
            }
    }
}

private void consumeAndPublish(final ConsumerRecords<String, String> records, Context parentContext) {
 Iterator<ConsumerRecord<String, String>> itr = records.iterator();
Span childSpan = null;
        try (Scope scope = parentContext.makeCurrent()) {
            childSpan = tracer.spanBuilder("child-span").startSpan();
            while (itr.hasNext()) {
              ringBuffer.publish(sequence);
            }
        }
        finally {
            childSpan.end();
        }
}