17.7. 初始化 Kafka 客户端的追踪

初始化 tracer，然后检测您的客户端应用程序以进行分布式追踪。您可以检测 Kafka producer 和消费者客户端，以及 Kafka Streams API 应用程序。您可以为 OpenTracing 或 OpenTelemetry 初始化 tracer。

使用一组追踪环境变量配置和初始化 tracer。

流程

在每个客户端应用程序中添加 tracer 的依赖项：

将 Maven 依赖项添加到客户端应用程序的 pom.xml 文件中：

OpenTelemetry 的依赖项

<dependency>
    <groupId>io.opentelemetry</groupId>
    <artifactId>opentelemetry-sdk-extension-autoconfigure</artifactId>
    <version>1.19.0.redhat-00002</version>
</dependency>
<dependency>
  <groupId>io.opentelemetry.instrumentation</groupId>
  <artifactId>opentelemetry-kafka-clients-{OpenTelemetryKafkaClient}</artifactId>
  <version>1.19.0.redhat-00002</version>
</dependency>
<dependency>
  <groupId>io.opentelemetry</groupId>
  <artifactId>opentelemetry-exporter-otlp</artifactId>
  <version>1.19.0.redhat-00002</version>
</dependency>

<dependency>
    <groupId>io.opentelemetry</groupId>
    <artifactId>opentelemetry-sdk-extension-autoconfigure</artifactId>
    <version>1.19.0.redhat-00002</version>
</dependency>
<dependency>
  <groupId>io.opentelemetry.instrumentation</groupId>
  <artifactId>opentelemetry-kafka-clients-{OpenTelemetryKafkaClient}</artifactId>
  <version>1.19.0.redhat-00002</version>
</dependency>
<dependency>
  <groupId>io.opentelemetry</groupId>
  <artifactId>opentelemetry-exporter-otlp</artifactId>
  <version>1.19.0.redhat-00002</version>
</dependency>

Copy to Clipboard

Toggle word wrap

OpenTracing 的依赖项

<dependency>
    <groupId>io.jaegertracing</groupId>
    <artifactId>jaeger-client</artifactId>
    <version>1.8.1.redhat-00002</version>
</dependency>
<dependency>
  <groupId>io.opentracing.contrib</groupId>
  <artifactId>opentracing-kafka-client</artifactId>
  <version>0.1.15.redhat-00006</version>
</dependency>

<dependency>
    <groupId>io.jaegertracing</groupId>
    <artifactId>jaeger-client</artifactId>
    <version>1.8.1.redhat-00002</version>
</dependency>
<dependency>
  <groupId>io.opentracing.contrib</groupId>
  <artifactId>opentracing-kafka-client</artifactId>
  <version>0.1.15.redhat-00006</version>
</dependency>

Copy to Clipboard

Toggle word wrap

使用追踪环境变量定义 tracer 的配置。
创建一个 tracer，它使用环境变量初始化：
为 OpenTelemetry 创建 tracer
```
OpenTelemetry ot = GlobalOpenTelemetry.get();
```
```
OpenTelemetry ot = GlobalOpenTelemetry.get();
```
Copy to Clipboard Toggle word wrap
为 OpenTracing 创建 tracer
```
Tracer tracer = Configuration.fromEnv().getTracer();
```
```
Tracer tracer = Configuration.fromEnv().getTracer();
```
Copy to Clipboard Toggle word wrap
将 tracer 注册为全局 tracer：
```
GlobalTracer.register(tracer);
```
```
GlobalTracer.register(tracer);
```
Copy to Clipboard Toggle word wrap
检测您的客户端：
- 第 17.8 节 “用于追踪的制作者和消费者的工具”
- 第 17.9 节 “为追踪检测 Kafka Streams 应用程序”

返回顶部

17.7. 初始化 Kafka 客户端的追踪

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links