15.3. 为 MirrorMaker 和 Kafka Connect 设置追踪
本节论述了如何配置 MirrorMaker、MirrorMaker 2.0 和 Kafka Connect 以实现分布式追踪。
您必须为每个组件启用 Jaeger tracer。
15.3.1. 为 MirrorMaker 启用追踪
通过将 Interceptor 属性作为消费者和制作者配置参数传递，为 MirrorMaker 启用分布式追踪。
信息从源集群跟踪到目标集群。跟踪数据记录进入和离开 MirrorMaker 组件的信息。
流程
- 配置并启用 Jaeger tracer。
编辑
/opt/kafka/config/consumer.properties文件。添加以下 Interceptor 属性：
consumer.interceptor.classes=io.opentracing.contrib.kafka.TracingConsumerInterceptor
编辑
/opt/kafka/config/producer.properties文件。添加以下 Interceptor 属性：
producer.interceptor.classes=io.opentracing.contrib.kafka.TracingProducerInterceptor
使用使用者和制作者配置文件作为参数启动 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
