17.6. MirrorMaker のトレースの有効化

手順

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

2. /opt/kafka/config/producer.properties ファイルでプロデューサートレースを設定します。

   次のトレースインターセプタープロパティーを追加します。

   OpenTelemetry のプロデューサープロパティー

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

   OpenTracing のプロデューサープロパティー

   producer.interceptor.classes=io.opentracing.contrib.kafka.TracingProducerInterceptor

3. 設定ファイルを作成します。

4. /opt/kafka/config/consumer.properties ファイルでコンシューマートレースを設定します。

   次のトレースインターセプタープロパティーを追加します。

   OpenTelemetry のコンシューマープロパティー

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

   OpenTracing のコンシューマープロパティー

   consumer.interceptor.classes=io.opentracing.contrib.kafka.TracingConsumerInterceptor

   トレースを有効にすると、Kafka MirrorMaker スクリプトの実行時にトレースを初期化します。

5. 設定ファイルを作成します。
6. トレースの 環境変数 を設定します。

7. プロデューサーおよびコンシューマー設定ファイルをパラメーターとして MirrorMaker を起動します。

   su - kafka
   /opt/kafka/bin/kafka-mirror-maker.sh \
   --producer.config /opt/kafka/config/producer.properties \
   --consumer.config /opt/kafka/config/consumer.properties \
   --num.streams=2

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