16.5. 为 MirrorMaker 2 启用追踪
通过在 MirrorMaker 2 属性文件中定义 Interceptor 属性，为 MirrorMaker 2 启用分布式追踪。信息在 Kafka 集群之间追踪。跟踪数据记录消息进入并离开 MirrorMaker 2 组件。
您可以启用使用 OpenTelemetry 的追踪。
流程
-
将追踪工件添加到
opt/kafka/libs目录中。 在
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
ByteArrayConverter会阻止 Kafka Connect 将消息标头（包含追踪 ID）转换为 base64 编码。这样可确保在源和目标集群中消息都相同。启用追踪后，您可以在运行 Kafka MirrorMaker 2 脚本时初始化追踪。
- 保存配置文件。
- 设置用于追踪 的环境变量。
使用生成者和消费者配置文件作为参数启动 MirrorMaker 2：
su - kafka /opt/kafka/bin/connect-mirror-maker.sh \ /opt/kafka/config/connect-mirror-maker.properties
MirrorMaker 2 的内部使用者和制作者现在被启用用于追踪。
