17.5. MirrorMaker 2의 추적 활성화

프로세스

1. opt/kafka/libs 디렉터리에 추적 아티팩트를 추가합니다.

2. 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

   CryostatArrayConverter 는 Kafka Connect가 메시지 헤더(추적 ID를 포함)를 base64 인코딩으로 변환하지 못하도록 합니다. 이렇게 하면 소스 및 대상 클러스터에서 메시지가 모두 동일합니다.

   추적이 활성화되면 Kafka MirrorMaker 2 스크립트를 실행할 때 추적을 초기화합니다.

3. 구성 파일을 저장합니다.
4. 추적의 환경 변수를 설정합니다.

5. 생산자 및 소비자 구성 파일을 매개변수로 사용하여 MirrorMaker 2를 시작합니다.

   su - kafka
   /opt/kafka/bin/connect-mirror-maker.sh \
   /opt/kafka/config/connect-mirror-maker.properties

   이제 추적을 위해 MirrorMaker 2의 내부 소비자와 생산자가 활성화됩니다.