15.3.2. 为 MirrorMaker 2.0 启用追踪

流程

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

   1

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

   2

   为 MirrorMaker 2.0 启用 Interceptors。

3. 使用 第 9.4 节 “使用 MirrorMaker 2.0 在 Kafka 集群间同步数据” 中的说明启动 MirrorMaker 2.0。