15.3. 为 MirrorMaker 和 Kafka Connect 设置追踪

流程

1. 配置并启用 Jaeger tracer。

2. 编辑 /opt/kafka/config/consumer.properties 文件。

   添加以下 Interceptor 属性：

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

   Copy to Clipboard Toggle word wrap

3. 编辑 /opt/kafka/config/producer.properties 文件。

   添加以下 Interceptor 属性：

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

   Copy to Clipboard Toggle word wrap

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

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

   Copy to Clipboard Toggle word wrap

流程

1. 配置并启用 Jaeger tracer。

2. 编辑 MirrorMaker 2.0 配置属性文件，./config/connect-mirror-maker.properties 并添加以下属性：

   header.converter=org.apache.kafka.connect.converters.ByteArrayConverter 

   1

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

   2

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

   Copy to Clipboard Toggle word wrap

   1

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

   2

   为 MirrorMaker 2.0 启用 Interceptors。

3. 使用 mirrorMaker 2.0 在 Kafka 集群间同步数据的说明启动 MirrorMaker 2.0。

流程

1. 配置并启用 Jaeger tracer。

2. 编辑相关的 Kafka Connect 配置文件。

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

3. 在配置文件中添加以下属性：

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

   Copy to Clipboard Toggle word wrap
4. 保存配置文件。
5. 设置追踪环境变量，然后在独立或分布式模式下运行 Kafka 连接。