用例
我从第三方mf系统接收消息到我的kafka队列。每个消息都有自己的唯一id。有一个.net核心kafka消息处理器，它从队列中读取消息并调用多个web API。
客观的
我想使用kafka队列上接收的消息的唯一id来实现端到端系统消息跟踪[如果相关的话]在我的堆栈中，我们使用serilog来丰富具有唯一消息id的日志，并开始探索opentelemetry.net仪器库。
问题
如何将消息的唯一id分配给kafak.net处理器中的system.diagnostics.activity.traceid，以便从此exe对任何api进行的任何httpclient调用都可以通过请求头进行复制。
或者也请让我知道，如果我用错误的方法来处理问题，并且已经有一个标准的解决方案来解决这类问题。