16.4. Kafka Connect에 대한 추적 활성화

프로세스

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

2. 관련 Kafka Connect 구성 파일에서 생산자 및 소비자 추적을 구성합니다.

   • 독립 실행형 모드에서 Kafka Connect를 실행하는 경우 /opt/kafka/config/connect-standalone.properties 파일을 편집합니다.
   • 분산 모드에서 Kafka Connect를 실행하는 경우 /opt/kafka/config/connect-distributed.properties 파일을 편집합니다.

   구성 파일에 다음 추적 인터셉터 속성을 추가합니다.

   OpenTelemetry 속성

   producer.interceptor.classes=io.opentelemetry.instrumentation.kafkaclients.TracingProducerInterceptor
   consumer.interceptor.classes=io.opentelemetry.instrumentation.kafkaclients.TracingConsumerInterceptor

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

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

5. 구성 파일을 매개 변수로 사용하여 독립 실행형 또는 분산 모드로 Kafka 연결을 시작합니다(연결 연결 속성 추가).

   독립 실행형 모드에서 Kafka 연결 실행

   su - kafka
   /opt/kafka/bin/connect-standalone.sh \
   /opt/kafka/config/connect-standalone.properties \
   connector1.properties \
   [connector2.properties ...]

   분산 모드에서 Kafka 연결 실행

   su - kafka
   /opt/kafka/bin/connect-distributed.sh /opt/kafka/config/connect-distributed.properties

   Kafka Connect의 내부 소비자 및 생산자가 이제 추적에 사용됩니다.