22.3. 分散トレースの設定

1. spec.template プロパティーで、トレーサーサービスを設定します。

   • トレーシング環境変数 をテンプレートの設定プロパティーとして使用します。
   • 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
     #...

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

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

   OpenTelemetry を使用した Kafka Bridge のトレース設定の例

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

2. リソースを作成または更新します。

   oc apply -f <resource_configuration_file>

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>

2. トレース環境変数 を使用して、トレーサーの設定を定義します。

3. 環境変数で初期化されるトレーサーを作成します。

   OpenTelemetry のトレーサーの作成

   OpenTelemetry ot = GlobalOpenTelemetry.get();

4. トレーサーをグローバルトレーサーとして登録します。

   GlobalTracer.register(tracer);

5. クライアントをインストルメント化します。

   • 「Kafka プロデューサーおよびコンシューマーをトレース用にインストルメント化」
   • 「Kafka Streams アプリケーションのトレース用のインストルメント化」

手順

1. トレーシングアーティファクトを Streams for Apache Kafka イメージの /opt/Kafka/libs/ ディレクトリーに追加します。

   新しいカスタムイメージを作成するための基本イメージとして、Red Hat Ecosystem Catalog の Kafka コンテナーイメージを使用できます。

   Zipkin の OpenTelemetry アーティファクト

   io.opentelemetry:opentelemetry-exporter-zipkin

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

   1

   接続先の Zipkin エンドポイントを指定します。

   2

   Zipkin エクスポーター。