15.4. 为 Kafka 连接启用追踪

流程

1. 在 opt/kafka/libs 目录中添加追踪工件。

2. 在相关的 Kafka Connect 配置文件中配置制作者和消费者追踪。

   • 如果您以独立模式运行 Kafka 连接，请编辑 /opt/kafka/config/connect-standalone.properties 文件。
   • 如果您以分布式模式运行 Kafka Connect，请编辑 /opt/kafka/config/connect-distributed.properties 文件。

   在配置文件中添加以下追踪拦截器属性：

   OpenTelemetry 的属性

   producer.interceptor.classes=io.opentelemetry.instrumentation.kafkaclients.TracingProducerInterceptor
   consumer.interceptor.classes=io.opentelemetry.instrumentation.kafkaclients.TracingConsumerInterceptor

   OpenTracing 的属性

   producer.interceptor.classes=io.opentracing.contrib.kafka.TracingProducerInterceptor
   consumer.interceptor.classes=io.opentracing.contrib.kafka.TracingConsumerInterceptor

   启用追踪后，您可以在运行 Kafka Connect 脚本时初始化追踪。

3. 保存配置文件。
4. 设置 用于追踪的环境变量。

5. 使用配置文件作为参数（以及任何连接器属性）在独立或分布式模式下启动 Kafka 连接：

   在独立模式下运行 Kafka 连接

   su - kafka
   /opt/kafka/bin/connect-standalone.sh \
   /opt/kafka/config/connect-standalone.properties \
   connector1.properties \
   [connector2.properties ...]

   在分布式模式下运行 Kafka 连接

   su - kafka
   /opt/kafka/bin/connect-distributed.sh /opt/kafka/config/connect-distributed.properties

   现在，启用了 Kafka Connect 的内部消费者和制作者进行追踪。