15.5. 为 MirrorMaker 2.0 启用追踪

流程

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

2. 在 opt/kafka/config/connect-mirror-maker.properties 文件中配置制作者和消费者追踪。

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

   OpenTelemetry 的属性

   header.converter=org.apache.kafka.connect.converters.ByteArrayConverter
   producer.interceptor.classes=io.opentelemetry.instrumentation.kafkaclients.TracingProducerInterceptor
   consumer.interceptor.classes=io.opentelemetry.instrumentation.kafkaclients.TracingConsumerInterceptor

   Copy to Clipboard Toggle word wrap

   OpenTracing 的属性

   header.converter=org.apache.kafka.connect.converters.ByteArrayConverter
   producer.interceptor.classes=io.opentracing.contrib.kafka.TracingProducerInterceptor
   consumer.interceptor.classes=io.opentracing.contrib.kafka.TracingConsumerInterceptor

   Copy to Clipboard Toggle word wrap

   ByteArrayConverter 会阻止 Kafka Connect 将消息标头（包含追踪 ID）转换为 base64 编码。这样可确保信息在源和目标集群中都是相同的。

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

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

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

   su - kafka
   /opt/kafka/bin/connect-mirror-maker.sh \
   /opt/kafka/config/connect-mirror-maker.properties

   Copy to Clipboard Toggle word wrap

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