微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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

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

相关推荐


Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其他元素将获得点击?
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。)
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbcDriver发生异常。为什么?
这是用Java进行XML解析的最佳库。
Java的PriorityQueue的内置迭代器不会以任何特定顺序遍历数据结构。为什么?
如何在Java中聆听按键时移动图像。
Java“Program to an interface”。这是什么意思?