用例
我收到来自第三方 MF 系统的消息到我的 kafka 队列。每条消息都有自己唯一的 id。有 .Net 核心 kafka 消息处理器，它从队列中读取消息并调用多个 Web API。
客观的
我想使用在 kafka 队列上接收到的消息的唯一 ID 来实现端到端系统消息跟踪。[如果相关]在我的堆栈中，我们使用 Serilog 来丰富具有唯一消息 ID 的日志，并开始探索 OpenTelemetry.Net 仪器库。
问题
如何在 Kafak .Net 处理器中将消息的唯一 ID 分配给System.Diagnostics.Activity.TraceID，以便从此 exe 对任何 API 进行的任何 HttpClient 调用都会通过请求标头复制。
或者，如果我以错误的方式处理问题并且已经有针对此类问题的标准解决方案，请告诉我。