如何通过.net core中kafka和web api之间的标准开放遥测协议进行消息跟踪

问题描述

用例

我从第三方 MF 系统接收消息到我的 kafka 队列。每条消息都有自己唯一的 ID。有.Net核心kafka消息处理器,从Queue读取消息并调用多个Web API。

目标

我想使用在 kafka 队列上收到的消息的唯一 ID 来实现端到端系统消息跟踪。 [如果它相关]在我的堆栈中,我们使用 Serilog 来丰富具有唯一消息 ID 的日志,并开始探索 OpenTelemetry.Net 检测库。

问题

如何在 Kafak .Net 处理器中为 System.Diagnostics.Activity.TraceID 分配唯一的消息 ID,以便从此 exe 对任何 API 进行的任何 HttpClient 调用都通过请求标头复制。

或者,如果我以错误的方式处理问题并且已经有针对此类问题的标准解决方案,也请告诉我。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)