19.4. Kafka Connect のトレースの有効化

手順

1. トレースアーティファクトを opt/kafka/libs ディレクトリーに追加します。

2. 関連する Kafka Connect 設定ファイルでプロデューサーとコンシューマーのトレースを設定します。

   • Kafka Connect をスタンドアロンモードで実行している場合は、./config/connect-standalone.properties ファイルを編集します。
   • Kafka Connect を分散モードで実行している場合は、./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 Connect を開始します。

   スタンドアロンモードでの Kafka Connect の実行

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

   分散モードでの Kafka Connect の起動

   ./bin/connect-distributed.sh ./config/connect-distributed.properties

   Kafka Connect の内部コンシューマーとプロデューサーがトレースできるようになりました。