15.5. 为 MirrorMaker 2 启用追踪

流程

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

   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

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

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

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

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

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

   MirrorMaker 2 的内部消费者和制作者现在被启用以进行追踪。