Distributed traces with messages consumers

[ttha3]

Hello, I have a questions about the concept of traces, spans in distributed system. I have a producer, a queue and a consumer. The producer put each message into the queue with the trace information. And the consumer polls a batch of messages to process. How the distributed tracing is done for this usecase. I mean, the Producer put Message_1 with {TraceId_Producer_1, SpanId_1}, Message_2 with {TraceId_Producer_2, SpandId_2} to the queue. In the consumer, only ONE instance of consumer will create 2 spans to process the Message_1 and Message_2. These two spans share the same TraceId_Consumer. How I can group all spans of Message_1 to the TraceId_Producer_1 and all spans of Message_2 to the TraceId_Producer_2? My idea is to have a map of service that shows the flow from the producer, queue and consumer for each message (so each TraceId_Producer_1 and TraceId_Producer_2). I see that I can you SpanLink but with the link, I need to click to the linkedSpan to visualize the forward/backward processing. But I prefer having all of the treatments in one map. Thanks for your idea.