16.3. MirrorMaker および Kafka Connect のトレース設定
本セクションでは、分散トレーシング用に MirrorMaker、MirrorMaker 2.0、および Kafka Connect を設定する方法を説明します。
コンポーネントごとに Jaeger トレーサーを有効にする必要があります。
16.3.1. MirrorMaker のトレースの有効化
Interceptor プロパティーをコンシューマーおよびプロデューサー設定パラメーターとして渡すことで、MirrorMaker の分散トレーシングを有効にします。
メッセージはソースクラスターからターゲットクラスターにトレースされます。トレースデータは、MirrorMaker コンポーネントに出入りするメッセージを記録します。
手順
- Jaeger トレーサーを設定し、有効にします。
/opt/kafka/config/consumer.propertiesファイルを編集します。以下のインターセプタープロパティーを追加します。
consumer.interceptor.classes=io.opentracing.contrib.kafka.TracingConsumerInterceptor
/opt/kafka/config/producer.propertiesファイルを編集します。以下のインターセプタープロパティーを追加します。
producer.interceptor.classes=io.opentracing.contrib.kafka.TracingProducerInterceptor
コンシューマーおよびプロデューサー設定ファイルをパラメーターとして MirrorMaker を起動します。
su - kafka /opt/kafka/bin/kafka-mirror-maker.sh --consumer.config /opt/kafka/config/consumer.properties --producer.config /opt/kafka/config/producer.properties --num.streams=2
