如何解决如何通过.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 举报,一经查实,本站将立刻删除。