How to continue the "Trace" from the "Producer" after obtaining the messages by "Consumer. ReceiveAsync"

[brotherhorse]

like this:

Messages<byte[]> msgs = await consumer.BatchReceiveAsync(cancellationToken).ConfigureAwait(false);

using (var activity=Activity.Current?.Source.StartActivity("MyBusiness")) { activity?.SetTag("business", "mybusiness"); _log.LogInformation("Hello world");
}

[brotherhorse]

like this:

Messages<byte[]> msg = await consumer.ReceiveAsync(cancellationToken).ConfigureAwait(false);

using (var activity=Activity.Current?.Source.StartActivity("MyBusiness")) { activity?.SetTag("business", "mybusiness"); _log.LogInformation("Hello world"); }

[Lanayx]

Hi! You can check out the example and the source code of the interceptor.

[brotherhorse]

I Got it, var parentContext = Propagators.DefaultTextMapPropagator.Extract(default, p.Properties, Getter);