17.6. 为 MirrorMaker 启用追踪

流程

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

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

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

   OpenTelemetry 的 producer 属性

   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 的内部使用者和制作者现已启用用于追踪。