红帽全球峰会16.6. 为 MirrorMaker 启用追踪
通过将 Interceptor 属性作为消费者和制作者配置参数传递，为 MirrorMaker 启用分布式追踪。消息从源集群追踪到目标集群。跟踪数据记录消息进入和离开 MirrorMaker 组件。
您可以启用使用 OpenTelemetry 的追踪。
流程
-
将追踪工件添加到
opt/kafka/libs目录中。 在
/opt/kafka/config/producer.properties文件中配置生产者追踪。添加以下追踪拦截器属性：
OpenTelemetry 的 producer 属性
producer.interceptor.classes=io.opentelemetry.instrumentation.kafkaclients.TracingProducerInterceptor
- 保存配置文件。
在
/opt/kafka/config/consumer.properties文件中配置消费者追踪。添加以下追踪拦截器属性：
OpenTelemetry 的消费者属性
consumer.interceptor.classes=io.opentelemetry.instrumentation.kafkaclients.TracingConsumerInterceptor
启用追踪后，您可以在运行 Kafka MirrorMaker 脚本时初始化追踪。
- 保存配置文件。
- 设置用于追踪 的环境变量。
使用生成者和消费者配置文件作为参数启动 MirrorMaker：
su - kafka /opt/kafka/bin/kafka-mirror-maker.sh \ --producer.config /opt/kafka/config/producer.properties \ --consumer.config /opt/kafka/config/consumer.properties \ --num.streams=2
MirrorMaker 的内部使用者和制作者现已启用用于追踪。
