当前位置: 首页 > 知识库问答 >
问题:

如何设置弹性节点APM分布式跟踪以使用Kafka和多个节点服务?

米飞龙
2023-03-14

我使用Kafka作为队列,节点服务使用Kafka节点生成和使用Kafka主题的消息。

我一直在使用自制的分布式跟踪解决方案,但现在我们正在转向弹性APM。

这似乎是为HTTP服务器量身定制的,但如何配置它以与Kafka一起使用呢?

我希望能够像下面这样跟踪事务:服务A向服务B发送一个HTTP请求,服务B向Kafka Topic C生成该请求,服务D从中使用该请求,服务D将一些数据放入Kafka Topic E,服务B从中使用该请求。

共有1个答案

殷建弼
2023-03-14

我与Elastic APM团队合作,他们刚刚推出了这个软件包:https://www.npmjs.com/package/elastic-apm-node

方向是相当不言自明的,工程就像一个魅力。

 类似资料:
  • 我尝试了以下命令- ,它给出了- 此CLI仅用于开发,不用于生产 https://docs.confluent.io/current/CLI/index.html 使用confluent_current:/tmp/confluent.w1s9b10m启动zookeeper zookeeper是[UP]启动kafka kafka是[UP] 启动schema-registry schema-regis

  • 我正在尝试使用python应用程序(基于django)进行测试,以便能够将事务跟踪推送到Elastic APM,稍后可以使用OpenDistro Elastic中的跟踪分析工具查看。 我试过以下方法 方法1: 然后,在文件中,我添加了以下代码,以直接将跟踪发送到弹性APM。 运行代码时,出现以下错误: 方法2: 由于方法1不起作用,我尝试在两者之间使用OpenTelemetry Collector

  • 在我们的应用程序中是一个节点。js前端与Java Spring后端对话。一切都是集装箱运输,在库伯内特斯运行。不久前,我们在前端和后端服务中添加了对Jaeger分布式跟踪的支持。杰格直到最近一直运转良好。 我们的Elasticsearch集群已经过时,所以我们升级了。这就要求对Jaeger进行升级--我们最终得到了以下信息: 这两个opentracing库都依赖于Jaeger Java客户端的0.

  • 我是Kafka的初来乍到,有一些基本的怀疑。我试着做一个Kafka建立的多节点(主动-主动)。情况如下:- 运行单个zookeeper(端口:2181) 创办了三家Kafka经纪人(9092、9093、9094) 创建单个主题测试(分区:1,复制3) 使用代理列表启动生产者(9092,9093) 在9092、9093、9094上启动了使用者,但它们都在使用相同的主题。 现在我怀疑的是,当我从生产者

  • 我在库伯内特斯集群中运行3个节点。每个节点都有相同的Pod myApp。我使用NodePort类型创建一个服务,以便所有3个节点都可以从外部访问。服务yaml如下所示 假设3个节点的节点IP端口为: 1.192.168.18.1:30010 2.192.68.18.2:30010 3.192.18.18.3:30010 我的问题是:<br>1.如果所有请求都来自IP为(192.168.18.1:3

  • 随着服务的数量和复杂性的增加,跨数据中心的统一的可观察性变得越来越重要。Linkerd 的跟踪和度量工具旨在汇总,为所有服务的健康提供广泛而细致的洞察。Linkerd 作为服务网格的角色使其成为可观察性信息的理想数据源,特别是在多语言环境中。 当请求通过多个服务时,使用传统的调试技术来识别性能瓶颈变得越来越困难。分布式跟踪提供通过多个服务的请求的整体视图,允许立即识别延迟问题。 使用 linker