22.3. 분산 추적 설정

1. spec.template 속성에서 tracer 서비스를 구성합니다.

   • 추적 환경 변수를 템플릿 구성 속성으로 사용합니다.
   • OpenTelemetry의 경우 spec.tracing.type 속성을 opentelemetry 로 설정합니다.

   OpenTelemetry를 사용한 Kafka Connect의 추적 구성 예

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaConnect
   metadata:
     name: my-connect-cluster
   spec:
     #...
     template:
       connectContainer:
         env:
           - name: OTEL_SERVICE_NAME
             value: my-otel-service
           - name: OTEL_EXPORTER_OTLP_ENDPOINT
             value: "http://otlp-host:4317"
     tracing:
       type: opentelemetry
     #...

   Copy to Clipboard Toggle word wrap

   OpenTelemetry를 사용한 MirrorMaker의 추적 구성 예

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaMirrorMaker
   metadata:
     name: my-mirror-maker
   spec:
     #...
     template:
       mirrorMakerContainer:
         env:
           - name: OTEL_SERVICE_NAME
             value: my-otel-service
           - name: OTEL_EXPORTER_OTLP_ENDPOINT
             value: "http://otlp-host:4317"
     tracing:
       type: opentelemetry
   #...

   Copy to Clipboard Toggle word wrap

   OpenTelemetry를 사용한 MirrorMaker 2의 추적 구성 예

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaMirrorMaker2
   metadata:
     name: my-mm2-cluster
   spec:
     #...
     template:
       connectContainer:
         env:
           - name: OTEL_SERVICE_NAME
             value: my-otel-service
           - name: OTEL_EXPORTER_OTLP_ENDPOINT
             value: "http://otlp-host:4317"
     tracing:
       type: opentelemetry
   #...

   Copy to Clipboard Toggle word wrap

   OpenTelemetry를 사용한 Kafka 브리지의 추적 구성 예

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaBridge
   metadata:
     name: my-bridge
   spec:
     #...
     template:
       bridgeContainer:
         env:
           - name: OTEL_SERVICE_NAME
             value: my-otel-service
           - name: OTEL_EXPORTER_OTLP_ENDPOINT
             value: "http://otlp-host:4317"
     tracing:
       type: opentelemetry
   #...

   Copy to Clipboard Toggle word wrap

2. 리소스를 생성하거나 업데이트합니다.

   oc apply -f <resource_configuration_file>

   Copy to Clipboard Toggle word wrap

1. 클라이언트 애플리케이션의 pom.xml 파일에 Maven 종속성을 추가합니다.

   OpenTelemetry 종속 항목

   <dependency>
       <groupId>io.opentelemetry.semconv</groupId>
       <artifactId>opentelemetry-semconv</artifactId>
       <version>1.21.0-alpha</version>
   </dependency>
   <dependency>
       <groupId>io.opentelemetry</groupId>
       <artifactId>opentelemetry-exporter-otlp</artifactId>
       <version>1.34.1</version>
       <exclusions>
           <exclusion>
               <groupId>io.opentelemetry</groupId>
               <artifactId>opentelemetry-exporter-sender-okhttp</artifactId>
           </exclusion>
       </exclusions>
   </dependency>
   <dependency>
       <groupId>io.opentelemetry</groupId>
       <artifactId>opentelemetry-exporter-sender-grpc-managed-channel</artifactId>
       <version>1.34.1</version>
       <scope>runtime</scope>
   </dependency>
   <dependency>
       <groupId>io.opentelemetry</groupId>
       <artifactId>opentelemetry-sdk-extension-autoconfigure</artifactId>
       <version>1.34.1</version>
   </dependency>
   <dependency>
       <groupId>io.opentelemetry.instrumentation</groupId>
       <artifactId>opentelemetry-kafka-clients-2.6</artifactId>
       <version>1.32.0-alpha</version>
   </dependency>
   <dependency>
       <groupId>io.opentelemetry</groupId>
       <artifactId>opentelemetry-sdk</artifactId>
       <version>1.34.1</version>
   </dependency>
   <dependency>
       <groupId>io.opentelemetry</groupId>
       <artifactId>opentelemetry-exporter-sender-jdk</artifactId>
       <version>1.34.1-alpha</version>
       <scope>runtime</scope>
   </dependency>
   <dependency>
       <groupId>io.grpc</groupId>
       <artifactId>grpc-netty-shaded</artifactId>
       <version>1.61.0</version>
   </dependency>

   Copy to Clipboard Toggle word wrap

2. 추적 환경 변수를 사용하여 추적 프로그램의 구성을 정의합니다.

3. 환경 변수로 초기화되는 추적기를 생성합니다.

   OpenTelemetry용 추적기 생성

   OpenTelemetry ot = GlobalOpenTelemetry.get();

   Copy to Clipboard Toggle word wrap

4. 추적기를 글로벌 추적기로 등록합니다.

   GlobalTracer.register(tracer);

   Copy to Clipboard Toggle word wrap

5. 클라이언트를 계측합니다.

   • 22.3.4절. “추적을 위한 생산자 및 소비자 처리”
   • 22.3.5절. “추적을 위한 Kafka Streams 애플리케이션 조정”

프로세스

1. Apache Kafka 이미지의 Streams의 /opt/kafka/libs/ 디렉터리에 추적 아티팩트를 추가합니다.

   Red Hat Ecosystem Catalog 에서 Kafka 컨테이너 이미지를 새 사용자 정의 이미지를 생성하기 위한 기본 이미지로 사용할 수 있습니다.

   Zipkin의 OpenTelemetry 아티팩트

   io.opentelemetry:opentelemetry-exporter-zipkin

   Copy to Clipboard Toggle word wrap

2. 새 추적 구현에 대해 추적 내보내기 및 끝점을 설정합니다.

   Zikpin 추적기 구성의 예

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaMirrorMaker2
   metadata:
     name: my-mm2-cluster
   spec:
     #...
     template:
       connectContainer:
         env:
           - name: OTEL_SERVICE_NAME
             value: my-zipkin-service
           - name: OTEL_EXPORTER_ZIPKIN_ENDPOINT
             value: http://zipkin-exporter-host-name:9411/api/v2/spans 

   1

   
           - name: OTEL_TRACES_EXPORTER
             value: zipkin 

   2

   
     tracing:
       type: opentelemetry
   #...

   Copy to Clipboard Toggle word wrap

   1

   연결할 Zipkin 엔드포인트를 지정합니다.

   2

   Zipkin 내보내기입니다.