15.6. 为 MirrorMaker 启用追踪

流程

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

2. 在 /opt/kafka/config/producer.properties 文件中配置生产者追踪。

   添加以下追踪拦截器属性：

   OpenTelemetry 的制作者属性

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

   Copy to Clipboard Toggle word wrap

   OpenTracing 的制作者属性

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

   Copy to Clipboard Toggle word wrap

3. 保存配置文件。

4. 在 /opt/kafka/config/consumer.properties 文件中配置消费者追踪。

   添加以下追踪拦截器属性：

   OpenTelemetry 的使用者属性

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

   Copy to Clipboard Toggle word wrap

   OpenTracing 的使用者属性

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

   Copy to Clipboard Toggle word wrap

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

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

7. 使用制作者和消费者配置文件作为参数启动 MirrorMaker：

   su - kafka
   /opt/kafka/bin/kafka-mirror-maker.sh \
   --producer.config /opt/kafka/config/producer.properties \
   --consumer.config /opt/kafka/config/consumer.properties \
   --num.streams=2

   Copy to Clipboard Toggle word wrap

   现在，为追踪启用 MirrorMaker 的内部使用者和制作者。