16.6. MirrorMaker의 추적 활성화
Interceptor 속성을 소비자 및 생산자 구성 매개변수로 전달하여 MirrorMaker에 대한 분산 추적을 활성화합니다. 메시지는 소스 클러스터에서 대상 클러스터로 추적됩니다. 추적 데이터는 MirrorMaker 구성 요소를 입력하고 나가는 메시지를 기록합니다.
OpenTelemetry를 사용하는 추적을 활성화할 수 있습니다.
프로세스
-
opt/kafka/libs디렉터리에 추적 아티팩트를 추가합니다. /opt/kafka/config/producer.properties파일에서 생산자 추적을 구성합니다.다음 추적 인터셉터 속성을 추가합니다.
OpenTelemetry의 생산자 속성
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의 내부 소비자 및 생산자가 활성화됩니다.